mjsax commented on a change in pull request #11447:
URL: https://github.com/apache/kafka/pull/11447#discussion_r741604615
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/GroupedTableOperationRepartitionNode.java
##
@@ -119,5 +119,10 @@
mjsax commented on pull request #11368:
URL: https://github.com/apache/kafka/pull/11368#issuecomment-958635275
@dajac It was originally planned for `3.1` -- did not pay attention to the
feature freeze deadline. The PR is low risk, and if it's ok with you, I am
happy to cherry-pick to
[
https://issues.apache.org/jira/browse/KAFKA-13425?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17437705#comment-17437705
]
RivenSun commented on KAFKA-13425:
--
Hi [~showuon]
Because the
RivenSun2 opened a new pull request #11460:
URL: https://github.com/apache/kafka/pull/11460
1. Enhance the annotation of KafkaConsumer#pause(...) method
2. Add log output when clearing the paused mark of topicPartitions
Story JIRA: https://issues.apache.org/jira/browse/KAFKA-13425
[
https://issues.apache.org/jira/browse/KAFKA-13422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17437699#comment-17437699
]
RivenSun commented on KAFKA-13422:
--
Hi [~guozhang] , [~showuon]
Can you promote the process of this
[
https://issues.apache.org/jira/browse/KAFKA-13428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17437697#comment-17437697
]
yuhuo commented on KAFKA-13428:
---
Thanks [~dajac]. that’s the same question.
> server hang on shutdown
>
jolshan opened a new pull request #11459:
URL: https://github.com/apache/kafka/pull/11459
With KAFKA-13102, we added topic IDs to the InitialFetchState and the
PartitionFetchState in order to send fetch requests using topic IDs when ibp is
3.1.
However, there are some cases where
[
https://issues.apache.org/jira/browse/KAFKA-12257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17437645#comment-17437645
]
Adem Efe Gencer commented on KAFKA-12257:
-
We were able to reproduce this issue in Kafka 2.4.
>
[
https://issues.apache.org/jira/browse/KAFKA-13373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17437620#comment-17437620
]
Anatoly Tsyganenko commented on KAFKA-13373:
And as I said error popped in init() on this
vamossagar12 commented on pull request #11211:
URL: https://github.com/apache/kafka/pull/11211#issuecomment-957932804
> Personally I'd suggest we enforce the rentention at the inner store, which
means:
>
> 1. for built-in in-memory stores, enforce at the InMemoryXXStore level.
>
sglass520 commented on pull request #11443:
URL: https://github.com/apache/kafka/pull/11443#issuecomment-957103498
@junrao I can confirm this issue running Kafka in WildFly. The code in
createSaslClient() is calling Java Security API to get the factory for
specified mechanism. However,
cmccabe closed pull request #11383:
URL: https://github.com/apache/kafka/pull/11383
--
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:
ableegoldman commented on a change in pull request #11424:
URL: https://github.com/apache/kafka/pull/11424#discussion_r740700461
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopologyBuilder.java
##
@@ -385,7 +385,7 @@ public
cadonna commented on pull request #11455:
URL: https://github.com/apache/kafka/pull/11455#issuecomment-957320922
@guozhangwang AFAICS not all `setState(DEAD)` are called during normal
processing in `GlobalStreamThread`. The `finally` clause in the `run()` is also
called when an exception
ambroff closed pull request #3110:
URL: https://github.com/apache/kafka/pull/3110
--
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:
kkonstantine commented on a change in pull request #11323:
URL: https://github.com/apache/kafka/pull/11323#discussion_r741409428
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/SubmittedRecords.java
##
@@ -0,0 +1,162 @@
+/*
+ * Licensed to the
sglass520 edited a comment on pull request #11443:
URL: https://github.com/apache/kafka/pull/11443#issuecomment-957103498
@junrao I can confirm this issue running Kafka in WildFly. The code in
createSaslClient() is calling Java Security API to get the factory for
specified mechanism.
[
https://issues.apache.org/jira/browse/KAFKA-13373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17437614#comment-17437614
]
Anatoly Tsyganenko commented on KAFKA-13373:
[~Ge] Unfortunately I didn't save sources,
dongjinleekr commented on a change in pull request #11430:
URL: https://github.com/apache/kafka/pull/11430#discussion_r741090237
##
File path:
clients/src/main/java/org/apache/kafka/common/security/JaasConfig.java
##
@@ -50,12 +50,24 @@
private final List configEntries;
ambroff closed pull request #4540:
URL: https://github.com/apache/kafka/pull/4540
--
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:
guozhangwang commented on pull request #11451:
URL: https://github.com/apache/kafka/pull/11451#issuecomment-958155691
Hi @showuon I think we were referring to different things :) There are
different places where we encode the assigned partitions as well as generation:
1) Inside the
dajac commented on pull request #11368:
URL: https://github.com/apache/kafka/pull/11368#issuecomment-957503502
@mjsax Do we plan to get this PR in 3.1? It seems that the PR has been
approved but not merge in time for the feature freeze.
--
This is an automated message from the Apache
showuon commented on pull request #11451:
URL: https://github.com/apache/kafka/pull/11451#issuecomment-957039415
@guozhangwang , thanks for your comment. Answer your question below.
> Only resetting the generation at the coordinator layer would not change
what user data would be
dajac merged pull request #11458:
URL: https://github.com/apache/kafka/pull/11458
--
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:
C0urante commented on a change in pull request #11323:
URL: https://github.com/apache/kafka/pull/11323#discussion_r741279732
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSourceTask.java
##
@@ -474,9 +479,24 @@ public boolean
showuon edited a comment on pull request #11451:
URL: https://github.com/apache/kafka/pull/11451#issuecomment-957039415
--
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
cadonna edited a comment on pull request #11455:
URL: https://github.com/apache/kafka/pull/11455#issuecomment-957320922
@guozhangwang AFAICS not all `setState(DEAD)` are called during normal
processing in `GlobalStreamThread`. The `finally` clause in `run()` is also
called when an
cadonna commented on a change in pull request #11455:
URL: https://github.com/apache/kafka/pull/11455#discussion_r740921447
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -655,10 +656,11 @@ public synchronized void onChange(final Thread
shirenchuang commented on a change in pull request #11453:
URL: https://github.com/apache/kafka/pull/11453#discussion_r740684255
##
File path: core/src/main/scala/kafka/server/ZkAdminManager.scala
##
@@ -152,7 +152,7 @@ class ZkAdminManager(val config: KafkaConfig,
shirenchuang commented on pull request #11453:
URL: https://github.com/apache/kafka/pull/11453#issuecomment-957037691
Thank you for your reply. I plan to repair the logic in kRaft together. In
addition, I will add an article to explain why sorting is needed and the
solution, and of course
guozhangwang commented on pull request #11211:
URL: https://github.com/apache/kafka/pull/11211#issuecomment-957002931
Personally I'd suggest we enforce the rentention at the inner store, which
means:
1) for built-in in-memory stores, enforce at the InMemoryXXStore level.
2) for
mimaison commented on a change in pull request #11450:
URL: https://github.com/apache/kafka/pull/11450#discussion_r741054431
##
File path:
connect/runtime/src/test/java/org/apache/kafka/connect/storage/FileOffsetBackingStoreTest.java
##
@@ -77,21 +74,17 @@ public void
cmccabe commented on pull request #11383:
URL: https://github.com/apache/kafka/pull/11383#issuecomment-958015023
Duplicate of #11417
--
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
RivenSun2 commented on pull request #11340:
URL: https://github.com/apache/kafka/pull/11340#issuecomment-957138929
Hi @showuon and @guozhangwang
Any suggestions for my last reply?
Thanks
--
This is an automated message from the Apache Git Service.
To respond to the message, please
vcrfxia commented on a change in pull request #11368:
URL: https://github.com/apache/kafka/pull/11368#discussion_r740646037
##
File path: streams/src/main/java/org/apache/kafka/streams/kstream/KTable.java
##
@@ -2117,12 +2118,37 @@
* @param the key type
jonmcewen commented on a change in pull request #8690:
URL: https://github.com/apache/kafka/pull/8690#discussion_r741175055
##
File path:
clients/src/main/java/org/apache/kafka/clients/producer/RoundRobinPartitioner.java
##
@@ -65,12 +65,20 @@ public int partition(String
kowshik edited a comment on pull request #11390:
URL: https://github.com/apache/kafka/pull/11390#issuecomment-956456320
@satishd It'd be helpful if you could please update the PR description
explaining the scope of the draft PR (in its current form) and what's remaining
to be done.
--
guozhangwang commented on pull request #11453:
URL: https://github.com/apache/kafka/pull/11453#issuecomment-956859211
+1 to @junrao 's comment, could you fix the sorting in
`ReplicationControlManager` too, and also add a unit test (similar to the one
you used to illustrate this issue) to
cmccabe commented on pull request #11326:
URL: https://github.com/apache/kafka/pull/11326#issuecomment-956773105
Seems like this is the same issue as
https://github.com/apache/kafka/pull/8690 ?
--
This is an automated message from the Apache Git Service.
To respond to the message,
mjsax commented on a change in pull request #11368:
URL: https://github.com/apache/kafka/pull/11368#discussion_r729526952
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/TableJoined.java
##
@@ -0,0 +1,119 @@
+/*
+ * Licensed to the Apache Software
cmccabe commented on a change in pull request #11353:
URL: https://github.com/apache/kafka/pull/11353#discussion_r740554575
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/SubscriptionState.java
##
@@ -423,9 +423,9 @@ synchronized int
junrao commented on a change in pull request #11453:
URL: https://github.com/apache/kafka/pull/11453#discussion_r740573525
##
File path: core/src/main/scala/kafka/server/ZkAdminManager.scala
##
@@ -152,7 +152,7 @@ class ZkAdminManager(val config: KafkaConfig,
junrao commented on pull request #11345:
URL: https://github.com/apache/kafka/pull/11345#issuecomment-956575167
@ccding : Thanks for reporting the test failure. This brings up a good
point. It's kind of weird to ever have recovery point > log end offset. I am
thinking that another
guozhangwang commented on pull request #11451:
URL: https://github.com/apache/kafka/pull/11451#issuecomment-958155691
Hi @showuon I think we were referring to different things :) There are
different places where we encode the assigned partitions as well as generation:
1) Inside the
kkonstantine commented on a change in pull request #11323:
URL: https://github.com/apache/kafka/pull/11323#discussion_r741409428
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/SubmittedRecords.java
##
@@ -0,0 +1,162 @@
+/*
+ * Licensed to the
cmccabe commented on pull request #11383:
URL: https://github.com/apache/kafka/pull/11383#issuecomment-958015023
Duplicate of #11417
--
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
cmccabe closed pull request #11383:
URL: https://github.com/apache/kafka/pull/11383
--
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:
vamossagar12 commented on pull request #11211:
URL: https://github.com/apache/kafka/pull/11211#issuecomment-957932804
> Personally I'd suggest we enforce the rentention at the inner store, which
means:
>
> 1. for built-in in-memory stores, enforce at the InMemoryXXStore level.
>
sglass520 commented on pull request #11443:
URL: https://github.com/apache/kafka/pull/11443#issuecomment-957103498
@junrao I can confirm this issue running Kafka in WildFly. The code in
createSaslClient() is calling Java Security API to get the factory for
specified mechanism. However,
cadonna commented on pull request #11455:
URL: https://github.com/apache/kafka/pull/11455#issuecomment-957320922
@guozhangwang AFAICS not all `setState(DEAD)` are called during normal
processing in `GlobalStreamThread`. The `finally` clause in the `run()` is also
called when an exception
ambroff closed pull request #3110:
URL: https://github.com/apache/kafka/pull/3110
--
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:
dongjinleekr commented on a change in pull request #11430:
URL: https://github.com/apache/kafka/pull/11430#discussion_r741090237
##
File path:
clients/src/main/java/org/apache/kafka/common/security/JaasConfig.java
##
@@ -50,12 +50,24 @@
private final List configEntries;
cmccabe commented on pull request #11326:
URL: https://github.com/apache/kafka/pull/11326#issuecomment-956773105
Seems like this is the same issue as
https://github.com/apache/kafka/pull/8690 ?
--
This is an automated message from the Apache Git Service.
To respond to the message,
ambroff closed pull request #4540:
URL: https://github.com/apache/kafka/pull/4540
--
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:
kowshik commented on pull request #11390:
URL: https://github.com/apache/kafka/pull/11390#issuecomment-956456320
@satishd It'd be helpful if you could please update the PR description
explaining the scope of the draft PR (in its current form) and what's remaining
to be done. Feel free to
Jorge Esteban Quilcate Otoya created KAFKA-13429:
Summary: Update gitignore to include new modules
Key: KAFKA-13429
URL: https://issues.apache.org/jira/browse/KAFKA-13429
Project:
dajac commented on pull request #11368:
URL: https://github.com/apache/kafka/pull/11368#issuecomment-957503502
@mjsax Do we plan to get this PR in 3.1? It seems that the PR has been
approved but not merge in time for the feature freeze.
--
This is an automated message from the Apache
guozhangwang commented on pull request #11453:
URL: https://github.com/apache/kafka/pull/11453#issuecomment-956859211
+1 to @junrao 's comment, could you fix the sorting in
`ReplicationControlManager` too, and also add a unit test (similar to the one
you used to illustrate this issue) to
showuon commented on pull request #11451:
URL: https://github.com/apache/kafka/pull/11451#issuecomment-957039415
@guozhangwang , thanks for your comment. Answer your question below.
> Only resetting the generation at the coordinator layer would not change
what user data would be
dajac merged pull request #11458:
URL: https://github.com/apache/kafka/pull/11458
--
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:
showuon edited a comment on pull request #11451:
URL: https://github.com/apache/kafka/pull/11451#issuecomment-957039415
--
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
C0urante commented on a change in pull request #11323:
URL: https://github.com/apache/kafka/pull/11323#discussion_r740365960
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/SubmittedRecords.java
##
@@ -0,0 +1,162 @@
+/*
+ * Licensed to the Apache
cadonna edited a comment on pull request #11455:
URL: https://github.com/apache/kafka/pull/11455#issuecomment-957320922
@guozhangwang AFAICS not all `setState(DEAD)` are called during normal
processing in `GlobalStreamThread`. The `finally` clause in `run()` is also
called when an
kowshik edited a comment on pull request #11390:
URL: https://github.com/apache/kafka/pull/11390#issuecomment-956456320
@satishd It'd be helpful if you could please update the PR description
explaining the scope of the draft PR (in its current form) and what's remaining
to be done.
--
ableegoldman commented on a change in pull request #11424:
URL: https://github.com/apache/kafka/pull/11424#discussion_r740700461
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopologyBuilder.java
##
@@ -385,7 +385,7 @@ public
cadonna commented on a change in pull request #11455:
URL: https://github.com/apache/kafka/pull/11455#discussion_r740921447
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -655,10 +656,11 @@ public synchronized void onChange(final Thread
shirenchuang commented on a change in pull request #11453:
URL: https://github.com/apache/kafka/pull/11453#discussion_r740684255
##
File path: core/src/main/scala/kafka/server/ZkAdminManager.scala
##
@@ -152,7 +152,7 @@ class ZkAdminManager(val config: KafkaConfig,
junrao commented on a change in pull request #11453:
URL: https://github.com/apache/kafka/pull/11453#discussion_r740573525
##
File path: core/src/main/scala/kafka/server/ZkAdminManager.scala
##
@@ -152,7 +152,7 @@ class ZkAdminManager(val config: KafkaConfig,
guozhangwang commented on pull request #11211:
URL: https://github.com/apache/kafka/pull/11211#issuecomment-957002931
Personally I'd suggest we enforce the rentention at the inner store, which
means:
1) for built-in in-memory stores, enforce at the InMemoryXXStore level.
2) for
rhauch commented on a change in pull request #11323:
URL: https://github.com/apache/kafka/pull/11323#discussion_r740478689
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSourceTask.java
##
@@ -474,9 +479,24 @@ public boolean commitOffsets()
cmccabe commented on a change in pull request #11353:
URL: https://github.com/apache/kafka/pull/11353#discussion_r740554575
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/SubscriptionState.java
##
@@ -423,9 +423,9 @@ synchronized int
shirenchuang commented on pull request #11453:
URL: https://github.com/apache/kafka/pull/11453#issuecomment-957037691
Thank you for your reply. I plan to repair the logic in kRaft together. In
addition, I will add an article to explain why sorting is needed and the
solution, and of course
mimaison commented on a change in pull request #11450:
URL: https://github.com/apache/kafka/pull/11450#discussion_r741054431
##
File path:
connect/runtime/src/test/java/org/apache/kafka/connect/storage/FileOffsetBackingStoreTest.java
##
@@ -77,21 +74,17 @@ public void
guozhangwang commented on a change in pull request #11449:
URL: https://github.com/apache/kafka/pull/11449#discussion_r740417424
##
File path: clients/src/main/java/org/apache/kafka/clients/NetworkClient.java
##
@@ -319,23 +319,29 @@ public void disconnect(String nodeId) {
junrao commented on pull request #11345:
URL: https://github.com/apache/kafka/pull/11345#issuecomment-956575167
@ccding : Thanks for reporting the test failure. This brings up a good
point. It's kind of weird to ever have recovery point > log end offset. I am
thinking that another
sglass520 edited a comment on pull request #11443:
URL: https://github.com/apache/kafka/pull/11443#issuecomment-957103498
@junrao I can confirm this issue running Kafka in WildFly. The code in
createSaslClient() is calling Java Security API to get the factory for
specified mechanism.
RivenSun2 commented on pull request #11340:
URL: https://github.com/apache/kafka/pull/11340#issuecomment-957138929
Hi @showuon and @guozhangwang
Any suggestions for my last reply?
Thanks
--
This is an automated message from the Apache Git Service.
To respond to the message, please
vcrfxia commented on a change in pull request #11368:
URL: https://github.com/apache/kafka/pull/11368#discussion_r740646037
##
File path: streams/src/main/java/org/apache/kafka/streams/kstream/KTable.java
##
@@ -2117,12 +2118,37 @@
* @param the key type
jonmcewen commented on a change in pull request #8690:
URL: https://github.com/apache/kafka/pull/8690#discussion_r741175055
##
File path:
clients/src/main/java/org/apache/kafka/clients/producer/RoundRobinPartitioner.java
##
@@ -65,12 +65,20 @@ public int partition(String
mjsax commented on a change in pull request #11368:
URL: https://github.com/apache/kafka/pull/11368#discussion_r729526952
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/TableJoined.java
##
@@ -0,0 +1,119 @@
+/*
+ * Licensed to the Apache Software
[
https://issues.apache.org/jira/browse/KAFKA-13426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-13426:
Labels: kip (was: )
> Add recordMetadata to StateStoreContext
>
[
https://issues.apache.org/jira/browse/KAFKA-13426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-13426:
Description:
KIP-791:
vamossagar12 commented on pull request #11211:
URL: https://github.com/apache/kafka/pull/11211#issuecomment-957932804
> Personally I'd suggest we enforce the rentention at the inner store, which
means:
>
> 1. for built-in in-memory stores, enforce at the InMemoryXXStore level.
>
C0urante commented on a change in pull request #11323:
URL: https://github.com/apache/kafka/pull/11323#discussion_r741279732
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSourceTask.java
##
@@ -474,9 +479,24 @@ public boolean
C0urante commented on a change in pull request #11323:
URL: https://github.com/apache/kafka/pull/11323#discussion_r741279732
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSourceTask.java
##
@@ -474,9 +479,24 @@ public boolean
[
https://issues.apache.org/jira/browse/KAFKA-13428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17437424#comment-17437424
]
David Jacot commented on KAFKA-13428:
-
[~yuhuo] Thanks for reporting this. It seems similar to
jonmcewen commented on a change in pull request #8690:
URL: https://github.com/apache/kafka/pull/8690#discussion_r741175055
##
File path:
clients/src/main/java/org/apache/kafka/clients/producer/RoundRobinPartitioner.java
##
@@ -65,12 +65,20 @@ public int partition(String
[
https://issues.apache.org/jira/browse/KAFKA-6080?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17437419#comment-17437419
]
Tom Bentley commented on KAFKA-6080:
[~sliebau],
[
https://issues.apache.org/jira/browse/KAFKA-13425?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17437413#comment-17437413
]
RivenSun commented on KAFKA-13425:
--
[~showuon]
In fact, the purpose of the modified code I added is to
[
https://issues.apache.org/jira/browse/KAFKA-13247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17437398#comment-17437398
]
Dongjin Lee commented on KAFKA-13247:
-
Hi [~tmargaryan]
Thank you for reporting this issue. I was
[
https://issues.apache.org/jira/browse/KAFKA-13183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aleksandr Sorokoumov reassigned KAFKA-13183:
Assignee: Aleksandr Sorokoumov
> Dropping nul key/value records upstream
dongjinleekr commented on a change in pull request #11430:
URL: https://github.com/apache/kafka/pull/11430#discussion_r741104074
##
File path:
clients/src/main/java/org/apache/kafka/common/security/JaasConfig.java
##
@@ -50,12 +50,24 @@
private final List configEntries;
dongjinleekr commented on a change in pull request #11430:
URL: https://github.com/apache/kafka/pull/11430#discussion_r741090237
##
File path:
clients/src/main/java/org/apache/kafka/common/security/JaasConfig.java
##
@@ -50,12 +50,24 @@
private final List configEntries;
[
https://issues.apache.org/jira/browse/KAFKA-6080?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17437377#comment-17437377
]
Sönke Liebau commented on KAFKA-6080:
-
Are there any developments around this? I recently came across
dongjinleekr commented on a change in pull request #11430:
URL: https://github.com/apache/kafka/pull/11430#discussion_r741090237
##
File path:
clients/src/main/java/org/apache/kafka/common/security/JaasConfig.java
##
@@ -50,12 +50,24 @@
private final List configEntries;
[
https://issues.apache.org/jira/browse/KAFKA-13348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Knowles Atchison Jr updated KAFKA-13348:
Description:
KAFKA-8586 added capture of Producer Exceptions which will kill the
[
https://issues.apache.org/jira/browse/KAFKA-13348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Knowles Atchison Jr updated KAFKA-13348:
Description:
KAFKA-8586 added capture of Producer Exceptions which will kill the
[
https://issues.apache.org/jira/browse/KAFKA-13348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Knowles Atchison Jr updated KAFKA-13348:
Description:
KAFKA-8586 added capture of Producer Exceptions which will kill the
[
https://issues.apache.org/jira/browse/KAFKA-13373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17437367#comment-17437367
]
Aleksandr Sorokoumov commented on KAFKA-13373:
--
[~htol] Can you please provide an example
[
https://issues.apache.org/jira/browse/KAFKA-13425?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17437366#comment-17437366
]
RivenSun commented on KAFKA-13425:
--
[~showuon]
So we have reached a consensus：When the rebalance is
1 - 100 of 168 matches
Mail list logo
