sknot-rh commented on pull request #10436:
URL: https://github.com/apache/kafka/pull/10436#issuecomment-91220
I am using this deprecated ctor in my tests. How can I set, for example
`source` option now? The other ctor has a package protected access.
```
ConfigEntry(String name, St
[
https://issues.apache.org/jira/browse/KAFKA-13257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17409248#comment-17409248
]
Satyam Bala commented on KAFKA-13257:
-
Currently *{color:#de350b}Blocked{color}* to
ccding commented on pull request #11293:
URL: https://github.com/apache/kafka/pull/11293#issuecomment-912200659
This PR fails `testCreateTopicsResponseMetadataAndConfig()`. DescribeTopic
doesn't return the internal configs, while the response of CreateTopic includes
the internal configs.
showuon commented on a change in pull request #11292:
URL: https://github.com/apache/kafka/pull/11292#discussion_r701534858
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/WindowStoreFetchIntegrationTest.java
##
@@ -0,0 +1,229 @@
+/*
+ * Licensed to th
showuon commented on pull request #11206:
URL: https://github.com/apache/kafka/pull/11206#issuecomment-912194561
@bbejeck , please take a look when available. Thank you.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
showuon commented on pull request #11086:
URL: https://github.com/apache/kafka/pull/11086#issuecomment-912194029
@dajac , I think this PR is good to get merged. WDYT?
Failed tests are unrelated. Thanks.
```
Build / JDK 11 and Scala 2.13 /
kafka.network.DynamicConnectionQuot
[
https://issues.apache.org/jira/browse/KAFKA-13270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ron Dagostino updated KAFKA-13270:
--
Description: The implementation of
https://issues.apache.org/jira/browse/ZOOKEEPER-3593 in Zoo
Ron Dagostino created KAFKA-13270:
-
Summary: Kafka may fail to connect to ZooKeeper, retry forever,
and never start
Key: KAFKA-13270
URL: https://issues.apache.org/jira/browse/KAFKA-13270
Project: Kaf
Rohit Bobade created KAFKA-13269:
Summary: Kafka Streams Aggregation data loss between instance
restarts and rebalances
Key: KAFKA-13269
URL: https://issues.apache.org/jira/browse/KAFKA-13269
Project:
hachikuji commented on a change in pull request #10914:
URL: https://github.com/apache/kafka/pull/10914#discussion_r701454478
##
File path: core/src/main/scala/kafka/log/LogCleanerManager.scala
##
@@ -198,8 +199,23 @@ private[log] class LogCleanerManager(val logDirs:
Seq[File]
hachikuji commented on pull request #11288:
URL: https://github.com/apache/kafka/pull/11288#issuecomment-912080811
@mimaison Ah, I missed you already opened JIRAs. Never mind my comment.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
hachikuji commented on a change in pull request #11288:
URL: https://github.com/apache/kafka/pull/11288#discussion_r701442901
##
File path:
clients/src/test/java/org/apache/kafka/common/requests/RequestResponseTest.java
##
@@ -706,6 +706,8 @@ private void checkDescribeConfigsR
ccding opened a new pull request #11293:
URL: https://github.com/apache/kafka/pull/11293
We haven't finished implementing KIP-405, therefore we should make
KIP-405 configs as defineInternal.
We may also want to port this change to 3.0 to avoid leaking these
configs to the doc.
[
https://issues.apache.org/jira/browse/KAFKA-13225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao resolved KAFKA-13225.
-
Fix Version/s: 3.1.0
Resolution: Fixed
merged the PR to trunk
> Controller skips sending UpdateM
junrao merged pull request #11255:
URL: https://github.com/apache/kafka/pull/11255
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscr..
junrao commented on a change in pull request #11033:
URL: https://github.com/apache/kafka/pull/11033#discussion_r701405911
##
File path:
storage/api/src/main/java/org/apache/kafka/server/log/remote/storage/RemoteLogMetadataManager.java
##
@@ -62,16 +63,17 @@
* @param rem
[
https://issues.apache.org/jira/browse/KAFKA-13261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17408977#comment-17408977
]
John Roesler commented on KAFKA-13261:
--
Hi [~xnix] ,
Your suspicion is correct.
guozhangwang commented on a change in pull request #11252:
URL: https://github.com/apache/kafka/pull/11252#discussion_r701252846
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBTimeOrderedWindowStore.java
##
@@ -33,172 +39,112 @@
* For key
guozhangwang commented on a change in pull request #11252:
URL: https://github.com/apache/kafka/pull/11252#discussion_r701252642
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamKStreamJoin.java
##
@@ -146,7 +146,7 @@ public void process(fi
guozhangwang commented on a change in pull request #11252:
URL: https://github.com/apache/kafka/pull/11252#discussion_r701252490
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamKStreamJoin.java
##
@@ -209,37 +208,36 @@ private void emitNon
guozhangwang commented on a change in pull request #11252:
URL: https://github.com/apache/kafka/pull/11252#discussion_r701251823
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredWindowStore.java
##
@@ -63,6 +63,10 @@
private InternalProc
guozhangwang commented on a change in pull request #11252:
URL: https://github.com/apache/kafka/pull/11252#discussion_r701251517
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/KeyAndJoinSideSerializer.java
##
@@ -55,9 +57,11 @@ public void configu
guozhangwang commented on a change in pull request #11252:
URL: https://github.com/apache/kafka/pull/11252#discussion_r701251294
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/KeyAndJoinSideDeserializer.java
##
@@ -48,15 +50,22 @@ public void conf
Guozhang Wang created KAFKA-13268:
-
Summary: Add more integration tests for Table Table FK joins with
repartitioning
Key: KAFKA-13268
URL: https://issues.apache.org/jira/browse/KAFKA-13268
Project: Ka
[
https://issues.apache.org/jira/browse/KAFKA-13261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17408967#comment-17408967
]
Guozhang Wang commented on KAFKA-13261:
---
Hello [~xnix] regarding "However, in a lo
junrao commented on a change in pull request #10914:
URL: https://github.com/apache/kafka/pull/10914#discussion_r701240936
##
File path:
clients/src/test/java/org/apache/kafka/common/record/MemoryRecordsTest.java
##
@@ -37,6 +40,7 @@
import java.util.Arrays;
import java.util
splett2 commented on a change in pull request #11255:
URL: https://github.com/apache/kafka/pull/11255#discussion_r701247464
##
File path: core/src/main/scala/kafka/controller/KafkaController.scala
##
@@ -628,9 +628,11 @@ class KafkaController(val config: KafkaConfig,
top
jsancio commented on a change in pull request #11186:
URL: https://github.com/apache/kafka/pull/11186#discussion_r701234135
##
File path:
metadata/src/main/java/org/apache/kafka/controller/ReplicationControlManager.java
##
@@ -804,7 +817,7 @@ void handleBrokerUnfenced(int brok
junrao commented on a change in pull request #11255:
URL: https://github.com/apache/kafka/pull/11255#discussion_r701230149
##
File path: core/src/main/scala/kafka/controller/KafkaController.scala
##
@@ -628,9 +628,11 @@ class KafkaController(val config: KafkaConfig,
topi
Gilles Philippart created KAFKA-13267:
-
Summary: InvalidPidMappingException: The producer attempted to use
a producer id which is not currently assigned to its transactional id
Key: KAFKA-13267
URL: https://is
[
https://issues.apache.org/jira/browse/KAFKA-13257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17408917#comment-17408917
]
Bruno Cadonna commented on KAFKA-13257:
---
We cannot upgrade the RocksDB version for
spena commented on a change in pull request #11252:
URL: https://github.com/apache/kafka/pull/11252#discussion_r701101588
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/KeyAndJoinSideDeserializer.java
##
@@ -48,15 +50,22 @@ public void configure(f
[
https://issues.apache.org/jira/browse/KAFKA-13261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17408786#comment-17408786
]
Tomas Forsman edited comment on KAFKA-13261 at 9/2/21, 2:34 PM:
--
lkokhreidze commented on pull request #10851:
URL: https://github.com/apache/kafka/pull/10851#issuecomment-911752624
Hi @cadonna,
I've addressed/replied to your comments. Thanks for the feedback.
FYI - I'll be offline from next week for 2 weeks.
--
This is an automated message from
lkokhreidze commented on a change in pull request #10851:
URL: https://github.com/apache/kafka/pull/10851#discussion_r701143273
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/ClientTagAwareStandbyTaskAssignor.java
##
@@ -0,0 +1,203
lkokhreidze commented on a change in pull request #10851:
URL: https://github.com/apache/kafka/pull/10851#discussion_r701142976
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/ClientTagAwareStandbyTaskAssignor.java
##
@@ -0,0 +1,203
lkokhreidze commented on a change in pull request #10851:
URL: https://github.com/apache/kafka/pull/10851#discussion_r701141903
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/ClientTagAwareStandbyTaskAssignor.java
##
@@ -0,0 +1,203
lkokhreidze commented on a change in pull request #10851:
URL: https://github.com/apache/kafka/pull/10851#discussion_r701137236
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/ClientTagAwareStandbyTaskAssignor.java
##
@@ -0,0 +1,203
[
https://issues.apache.org/jira/browse/KAFKA-13266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot updated KAFKA-13266:
Description:
`ReplicationTest.test_replication_with_broker_failure` in KRaft mode sometimes
fail
David Jacot created KAFKA-13266:
---
Summary: `InitialFetchState` should be created after partition is
removed from the fetchers
Key: KAFKA-13266
URL: https://issues.apache.org/jira/browse/KAFKA-13266
Proj
[
https://issues.apache.org/jira/browse/KAFKA-13257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17408852#comment-17408852
]
Satyam Bala commented on KAFKA-13257:
-
shall we open this ticket, until kafka-stream
[
https://issues.apache.org/jira/browse/KAFKA-13261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17408786#comment-17408786
]
Tomas Forsman edited comment on KAFKA-13261 at 9/2/21, 1:25 PM:
--
[
https://issues.apache.org/jira/browse/KAFKA-13261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tomas Forsman updated KAFKA-13261:
--
Attachment: KafkaTest.java
> KTable to KTable foreign key join loose events when using several
cadonna commented on a change in pull request #10851:
URL: https://github.com/apache/kafka/pull/10851#discussion_r701068792
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/ClientTagAwareStandbyTaskAssignor.java
##
@@ -0,0 +1,203 @@
+
vamossagar12 commented on pull request #11211:
URL: https://github.com/apache/kafka/pull/11211#issuecomment-911654379
> > @showuon , is there an existing integration test for Metered classes? I
tried to find one to add the relevant tests but couldnt't find one..
>
> Sorry for late re
scholzj commented on pull request #11174:
URL: https://github.com/apache/kafka/pull/11174#issuecomment-911647841
Great, thanks.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comme
[
https://issues.apache.org/jira/browse/KAFKA-13261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17408786#comment-17408786
]
Tomas Forsman edited comment on KAFKA-13261 at 9/2/21, 12:50 PM:
-
mimaison commented on pull request #11174:
URL: https://github.com/apache/kafka/pull/11174#issuecomment-911644486
@scholzj Yes that's the plan, I'll do it when merging into 3.0 reopens
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on t
lkokhreidze commented on a change in pull request #10851:
URL: https://github.com/apache/kafka/pull/10851#discussion_r701038718
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/ClientTagAwareStandbyTaskAssignor.java
##
@@ -0,0 +1,203
[
https://issues.apache.org/jira/browse/KAFKA-13261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17408786#comment-17408786
]
Tomas Forsman edited comment on KAFKA-13261 at 9/2/21, 12:44 PM:
-
[
https://issues.apache.org/jira/browse/KAFKA-13261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17408786#comment-17408786
]
Tomas Forsman edited comment on KAFKA-13261 at 9/2/21, 12:44 PM:
-
[
https://issues.apache.org/jira/browse/KAFKA-13261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17408786#comment-17408786
]
Tomas Forsman edited comment on KAFKA-13261 at 9/2/21, 12:41 PM:
-
[
https://issues.apache.org/jira/browse/KAFKA-13261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17408786#comment-17408786
]
Tomas Forsman commented on KAFKA-13261:
---
Hi [~guozhang] and [~abellemare], thank y
lkokhreidze commented on a change in pull request #10851:
URL: https://github.com/apache/kafka/pull/10851#discussion_r701038718
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/ClientTagAwareStandbyTaskAssignor.java
##
@@ -0,0 +1,203
showuon commented on pull request #11227:
URL: https://github.com/apache/kafka/pull/11227#issuecomment-911629109
Integration tests added, but found a bug that will fail these tests. Will
wait for the PR got merged and continue this PR. Thanks.
https://github.com/apache/kafka/pull/11292
-
scholzj commented on pull request #11174:
URL: https://github.com/apache/kafka/pull/11174#issuecomment-911607580
@mimaison Will this also get into the 3.0.x release stream? I know it is
probably late for 3.0.0 which already has RCs, so that is fine. But it would be
nice to have it in 3.0.1
vamossagar12 commented on pull request #10798:
URL: https://github.com/apache/kafka/pull/10798#issuecomment-911592247
@guozhangwang , these errors are not due to the changes in this PR:
`imported `Named` is permanently hidden by definition of type Named in
package kstream`
[
https://issues.apache.org/jira/browse/KAFKA-13257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17408759#comment-17408759
]
Bruno Cadonna commented on KAFKA-13257:
---
[~satyam.b...@gmail.com] Using a Kafka St
Ayyandurai Mani created KAFKA-13265:
---
Summary: Kafka consumers disappearing after certain point of time
Key: KAFKA-13265
URL: https://issues.apache.org/jira/browse/KAFKA-13265
Project: Kafka
ashishpatil09 commented on pull request #7898:
URL: https://github.com/apache/kafka/pull/7898#issuecomment-911500667
Hi Guys
Is there any plan to release this fix soon?
Thanks
Ashish
--
This is an automated message from the Apache Git Service.
To respond to the message, please lo
cadonna commented on a change in pull request #10851:
URL: https://github.com/apache/kafka/pull/10851#discussion_r700864299
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/ClientTagAwareStandbyTaskAssignor.java
##
@@ -0,0 +1,203 @@
+
showuon commented on pull request #11292:
URL: https://github.com/apache/kafka/pull/11292#issuecomment-911448780
@jeqo @ableegoldman @guozhangwang , please help review this PR. Thank you.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
showuon commented on a change in pull request #11292:
URL: https://github.com/apache/kafka/pull/11292#discussion_r700910107
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryWindowStore.java
##
@@ -499,10 +499,14 @@ public void close() {
showuon commented on a change in pull request #11292:
URL: https://github.com/apache/kafka/pull/11292#discussion_r700908241
##
File path:
streams/src/test/java/org/apache/kafka/streams/state/internals/AbstractWindowBytesStoreTest.java
##
@@ -1176,6 +1105,7 @@ private void putF
dadufour commented on pull request #11174:
URL: https://github.com/apache/kafka/pull/11174#issuecomment-911390634
Thanks for the feedback
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the spec
mimaison commented on pull request #11174:
URL: https://github.com/apache/kafka/pull/11174#issuecomment-911379969
@akatona84 Thanks for the fix and sorry again for the delay merging it.
@dadufour At this point, it's unlikely there will be a 2.7.2 release. I've
backported it to 2.8 so
[
https://issues.apache.org/jira/browse/KAFKA-9747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison updated KAFKA-9747:
--
Fix Version/s: 2.8.1
> No tasks created for a connector
>
>
>
[
https://issues.apache.org/jira/browse/KAFKA-9366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17408666#comment-17408666
]
Ashish Patil commented on KAFKA-9366:
-
Hi Guys
Is there any plan to fix this issue s
showuon opened a new pull request #11292:
URL: https://github.com/apache/kafka/pull/11292
We forgot to make each segment in reverse order (i.e. in `descendingMap`) in
`InMemoryWindowStore`. Fix it and add integration tests for it.
### Committer Checklist (excluded from commit message
mimaison merged pull request #11174:
URL: https://github.com/apache/kafka/pull/11174
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscr
Luke Chen created KAFKA-13264:
-
Summary: backwardFetch in InMemoryWindowStore doesn't return in
reverse order
Key: KAFKA-13264
URL: https://issues.apache.org/jira/browse/KAFKA-13264
Project: Kafka
71 matches
Mail list logo
