mdedetrich commented on PR #12524:
URL: https://github.com/apache/kafka/pull/12524#issuecomment-1219138597
PR has been rebased and pushed which fixes the problem described earlier,
i.e. usage of `when(storeMetadata.offset()).thenReturn(null);`
--
This is an automated message from the Apac
dajac merged PR #12526:
URL: https://github.com/apache/kafka/pull/12526
--
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...@kafka.apache.or
mimaison commented on code in PR #12509:
URL: https://github.com/apache/kafka/pull/12509#discussion_r948858351
##
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/distributed/WorkerCoordinatorTest.java:
##
@@ -432,30 +422,28 @@ public void testLeaderPerformAssignme
mimaison merged PR #12410:
URL: https://github.com/apache/kafka/pull/12410
--
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...@kafka.apache
mimaison commented on PR #12375:
URL: https://github.com/apache/kafka/pull/12375#issuecomment-1219305270
Discussions should happen on the mailing lists, closing.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
mimaison closed pull request #12375: what is Best Practices of kafka mirror
maker 2
URL: https://github.com/apache/kafka/pull/12375
--
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
dengziming commented on code in PR #12533:
URL: https://github.com/apache/kafka/pull/12533#discussion_r948947569
##
metadata/src/main/java/org/apache/kafka/controller/BrokersToIsrs.java:
##
@@ -191,7 +191,7 @@ void update(Uuid topicId, int partitionId, int[] prevIsr,
int[] next
mimaison merged PR #12471:
URL: https://github.com/apache/kafka/pull/12471
--
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...@kafka.apache
mimaison commented on PR #12284:
URL: https://github.com/apache/kafka/pull/12284#issuecomment-1219323255
Can you also update `bin/kafka-run-class.sh` and
`bin/windows/kafka-run-class.bat`?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log o
mdedetrich commented on PR #12284:
URL: https://github.com/apache/kafka/pull/12284#issuecomment-1219328536
@mimaison
> Can you also update bin/kafka-run-class.sh and
bin/windows/kafka-run-class.bat?
I just checked those files and it seems that this is not necessary because
we are
mimaison commented on PR #12284:
URL: https://github.com/apache/kafka/pull/12284#issuecomment-1219339690
Ah yes, you're right! My bad
--
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
mdedetrich opened a new pull request, #12534:
URL: https://github.com/apache/kafka/pull/12534
In Scala its standard practice to use _ whenever you are initializing
variables. In regard to implementation, for object references
_ initialization maps to null so there is no change in behavi
mdedetrich commented on PR #12534:
URL: https://github.com/apache/kafka/pull/12534#issuecomment-1219341093
@mimaison Since you reviewed https://github.com/apache/kafka/pull/12471 can
you have a look at this PR (once the CI is happy of course)?
--
This is an automated message from the Apac
[
https://issues.apache.org/jira/browse/KAFKA-14171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Justinwins updated KAFKA-14171:
---
Description:
- This seems a small bug (or improvment) ,but it really impacts perf of mm2.
- When D
Justinwins created KAFKA-14171:
--
Summary: mm2-offsets topic should be set retention.ms=1h or less
as default
Key: KAFKA-14171
URL: https://issues.apache.org/jira/browse/KAFKA-14171
Project: Kafka
showuon commented on PR #12525:
URL: https://github.com/apache/kafka/pull/12525#issuecomment-1219445407
@ijuma @aiquestion , please take a look. Thanks.
Failed tests are unrelated:
```
Build / JDK 8 and Scala 2.12 /
org.apache.kafka.connect.mirror.integration.MirrorConnector
Ge opened a new pull request, #12535:
URL: https://github.com/apache/kafka/pull/12535
This patch fixes another incorrect version check in the FK code and adds
unit tests that would have caught this bug.
### Committer Checklist (excluded from commit message)
- [ ] Verify design
Ge commented on PR #12535:
URL: https://github.com/apache/kafka/pull/12535#issuecomment-1219496131
@vvcephei Can you please review?
--
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 specifi
mimaison opened a new pull request, #12536:
URL: https://github.com/apache/kafka/pull/12536
Cache the Kafka cluster Id once it has been retrieved to avoid creating many
Admin clients at startup.
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implemen
dplavcic commented on PR #12492:
URL: https://github.com/apache/kafka/pull/12492#issuecomment-1219679741
> @cadonna and @dplavcic I hope that the new version has addressed all
comments up to now. Thank you in advance for the review!
LGTM!
--
This is an automated message from the Ap
cmccabe commented on code in PR #12533:
URL: https://github.com/apache/kafka/pull/12533#discussion_r949351073
##
metadata/src/main/java/org/apache/kafka/controller/BrokersToIsrs.java:
##
@@ -191,7 +191,7 @@ void update(Uuid topicId, int partitionId, int[] prevIsr,
int[] nextIsr
cmccabe commented on code in PR #12533:
URL: https://github.com/apache/kafka/pull/12533#discussion_r949351073
##
metadata/src/main/java/org/apache/kafka/controller/BrokersToIsrs.java:
##
@@ -191,7 +191,7 @@ void update(Uuid topicId, int partitionId, int[] prevIsr,
int[] nextIsr
cmccabe commented on code in PR #12533:
URL: https://github.com/apache/kafka/pull/12533#discussion_r949351947
##
core/src/test/scala/unit/kafka/integration/KafkaServerTestHarness.scala:
##
@@ -173,11 +173,11 @@ abstract class KafkaServerTestHarness extends
QuorumTestHarness {
Ge commented on PR #12535:
URL: https://github.com/apache/kafka/pull/12535#issuecomment-1219722137
Test failure:
```
[2022-08-18T14:24:17.527Z] FetchRequestTestDowngrade >
testTopicIdIsRemovedFromFetcherWhenControllerDowngrades() STARTED
[2022-08-18T14:24:17.527Z]
integrati
vvcephei commented on code in PR #12535:
URL: https://github.com/apache/kafka/pull/12535#discussion_r949388743
##
streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionStoreReceiveProcessorSupplier.java:
##
@@ -91,7 +91,7 @@ public void proc
dplavcic commented on code in PR #12505:
URL: https://github.com/apache/kafka/pull/12505#discussion_r949392447
##
streams/src/test/java/org/apache/kafka/streams/state/internals/KeyValueStoreBuilderTest.java:
##
@@ -126,27 +121,15 @@ public void shouldThrowNullPointerIfInnerIsNul
Ge commented on code in PR #12535:
URL: https://github.com/apache/kafka/pull/12535#discussion_r949396415
##
streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionStoreReceiveProcessorSupplier.java:
##
@@ -91,7 +91,7 @@ public void proces
Ge commented on code in PR #12535:
URL: https://github.com/apache/kafka/pull/12535#discussion_r949398138
##
streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/CombinedKey.java:
##
@@ -38,8 +38,22 @@ public KP getPrimaryKey() {
return pri
Ge commented on PR #12535:
URL: https://github.com/apache/kafka/pull/12535#issuecomment-1219734073
I added an upgrade test back in https://github.com/apache/kafka/pull/12122.
Unfortunately, it didn't catch these version check bugs. I am going to figure
out why and improve the test. I'd
Ge commented on code in PR #12535:
URL: https://github.com/apache/kafka/pull/12535#discussion_r949398138
##
streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/CombinedKey.java:
##
@@ -38,8 +38,22 @@ public KP getPrimaryKey() {
return pri
mimaison commented on PR #12534:
URL: https://github.com/apache/kafka/pull/12534#issuecomment-1219749268
Thanks for the PR!
I did a quick search and it looks like there are 200+ such instances across
40+ files. If you want to address them all, maybe let's group them in 1 or 2
PRs.
--
akhileshchg commented on code in PR #12533:
URL: https://github.com/apache/kafka/pull/12533#discussion_r949415430
##
metadata/src/main/java/org/apache/kafka/controller/BrokersToIsrs.java:
##
@@ -191,7 +191,7 @@ void update(Uuid topicId, int partitionId, int[] prevIsr,
int[] nex
akhileshchg commented on code in PR #12533:
URL: https://github.com/apache/kafka/pull/12533#discussion_r949414831
##
core/src/test/scala/unit/kafka/integration/KafkaServerTestHarness.scala:
##
@@ -173,11 +173,11 @@ abstract class KafkaServerTestHarness extends
QuorumTestHarness
akhileshchg commented on code in PR #12533:
URL: https://github.com/apache/kafka/pull/12533#discussion_r949419718
##
core/src/test/scala/unit/kafka/server/DeleteTopicsRequestTest.scala:
##
@@ -32,10 +32,45 @@ import org.apache.kafka.common.requests.MetadataResponse
import org.j
ahuang98 commented on code in PR #12479:
URL: https://github.com/apache/kafka/pull/12479#discussion_r940527628
##
core/src/test/scala/integration/kafka/api/RackAwareAutoTopicCreationTest.scala:
##
@@ -37,29 +43,57 @@ class RackAwareAutoTopicCreationTest extends
KafkaServerTestH
ahuang98 commented on code in PR #12479:
URL: https://github.com/apache/kafka/pull/12479#discussion_r942970441
##
core/src/test/scala/unit/kafka/admin/DeleteTopicTest.scala:
##
@@ -187,264 +220,337 @@ class DeleteTopicTest extends QuorumTestHarness {
}.toSet
}
- @Test
mdedetrich commented on PR #12534:
URL: https://github.com/apache/kafka/pull/12534#issuecomment-1219791330
Sure thing will do.
--
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
vvcephei commented on code in PR #12535:
URL: https://github.com/apache/kafka/pull/12535#discussion_r949454530
##
streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionStoreReceiveProcessorSupplier.java:
##
@@ -91,7 +91,7 @@ public void proc
vvcephei commented on code in PR #12535:
URL: https://github.com/apache/kafka/pull/12535#discussion_r949454836
##
streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/CombinedKey.java:
##
@@ -38,8 +38,22 @@ public KP getPrimaryKey() {
return p
akhileshchg commented on code in PR #12533:
URL: https://github.com/apache/kafka/pull/12533#discussion_r949455336
##
core/src/test/scala/unit/kafka/integration/KafkaServerTestHarness.scala:
##
@@ -173,11 +173,11 @@ abstract class KafkaServerTestHarness extends
QuorumTestHarness
cmccabe commented on code in PR #12533:
URL: https://github.com/apache/kafka/pull/12533#discussion_r949455413
##
core/src/test/scala/unit/kafka/integration/KafkaServerTestHarness.scala:
##
@@ -173,11 +173,11 @@ abstract class KafkaServerTestHarness extends
QuorumTestHarness {
vvcephei commented on PR #12535:
URL: https://github.com/apache/kafka/pull/12535#issuecomment-1219795362
Test failure was unrelated:
```
[Build / JDK 11 and Scala 2.13 /
integration.kafka.server.FetchRequestTestDowngrade.testTopicIdIsRemovedFromFetcherWhenControllerDowngrades()](ht
yashmayya commented on code in PR #12509:
URL: https://github.com/apache/kafka/pull/12509#discussion_r949456092
##
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/distributed/WorkerCoordinatorTest.java:
##
@@ -432,30 +422,28 @@ public void testLeaderPerformAssignm
vvcephei merged PR #12535:
URL: https://github.com/apache/kafka/pull/12535
--
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...@kafka.apache
akhileshchg commented on PR #12533:
URL: https://github.com/apache/kafka/pull/12533#issuecomment-1219803916
@dengziming @cmccabe I addressed your comments. I have question regarding
KafkaTestHarness changes. Please let me know your thoughts.
--
This is an automated message from the Apach
guozhangwang opened a new pull request, #12537:
URL: https://github.com/apache/kafka/pull/12537
While reviewing KIP-588 and KIP-691 I went through the exception throwing
behavior and wanted to improve the related javadocs a little bit.
### Committer Checklist (excluded from commit mes
hachikuji opened a new pull request, #12538:
URL: https://github.com/apache/kafka/pull/12538
We have been seeing a few exceptions like the following when running
integration tests:
```
[2022-08-18 13:02:59,470] ERROR [ControllerApis nodeId=3000] Unexpected
error handling request Reque
cmccabe commented on code in PR #12533:
URL: https://github.com/apache/kafka/pull/12533#discussion_r949580181
##
core/src/test/scala/unit/kafka/integration/KafkaServerTestHarness.scala:
##
@@ -173,11 +173,11 @@ abstract class KafkaServerTestHarness extends
QuorumTestHarness {
soarez commented on PR #12198:
URL: https://github.com/apache/kafka/pull/12198#issuecomment-1219955676
@dajac thanks for having a look and for the suggestion. `RFC2606.invalid` is
a better choice, especially since we're already using it.
--
This is an automated message from the Apache Git
mdedetrich commented on PR #12534:
URL: https://github.com/apache/kafka/pull/12534#issuecomment-1219980341
@mimaison PR has been updated as you wanted.
--
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 g
ijuma commented on code in PR #12538:
URL: https://github.com/apache/kafka/pull/12538#discussion_r949628021
##
core/src/test/java/kafka/testkit/KafkaClusterTestKit.java:
##
@@ -275,15 +275,15 @@ metaProperties, config, new MetadataRecordSerde(),
metadataPartition, KafkaRaftS
ijuma commented on code in PR #12538:
URL: https://github.com/apache/kafka/pull/12538#discussion_r949628460
##
core/src/test/java/kafka/testkit/KafkaClusterTestKit.java:
##
@@ -275,15 +275,15 @@ metaProperties, config, new MetadataRecordSerde(),
metadataPartition, KafkaRaftS
hachikuji commented on code in PR #12538:
URL: https://github.com/apache/kafka/pull/12538#discussion_r949654185
##
core/src/test/java/kafka/testkit/KafkaClusterTestKit.java:
##
@@ -275,15 +275,15 @@ metaProperties, config, new MetadataRecordSerde(),
metadataPartition, KafkaRaft
hachikuji commented on code in PR #12538:
URL: https://github.com/apache/kafka/pull/12538#discussion_r949654185
##
core/src/test/java/kafka/testkit/KafkaClusterTestKit.java:
##
@@ -275,15 +275,15 @@ metaProperties, config, new MetadataRecordSerde(),
metadataPartition, KafkaRaft
hachikuji commented on code in PR #12513:
URL: https://github.com/apache/kafka/pull/12513#discussion_r949590579
##
metadata/src/main/java/org/apache/kafka/metadata/bootstrap/BootstrapDirectory.java:
##
@@ -0,0 +1,134 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) un
cmccabe commented on code in PR #12513:
URL: https://github.com/apache/kafka/pull/12513#discussion_r949665053
##
metadata/src/main/java/org/apache/kafka/metadata/bootstrap/BootstrapDirectory.java:
##
@@ -0,0 +1,134 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) unde
cmccabe commented on code in PR #12513:
URL: https://github.com/apache/kafka/pull/12513#discussion_r949665682
##
metadata/src/main/java/org/apache/kafka/metadata/bootstrap/BootstrapDirectory.java:
##
@@ -0,0 +1,134 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) unde
cmccabe commented on code in PR #12513:
URL: https://github.com/apache/kafka/pull/12513#discussion_r949666958
##
metadata/src/main/java/org/apache/kafka/metadata/bootstrap/BootstrapDirectory.java:
##
@@ -0,0 +1,134 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) unde
cmccabe commented on code in PR #12513:
URL: https://github.com/apache/kafka/pull/12513#discussion_r949668350
##
metadata/src/main/java/org/apache/kafka/metadata/bootstrap/BootstrapDirectory.java:
##
@@ -0,0 +1,134 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) unde
cmccabe commented on code in PR #12513:
URL: https://github.com/apache/kafka/pull/12513#discussion_r949670514
##
metadata/src/main/java/org/apache/kafka/metadata/bootstrap/BootstrapDirectory.java:
##
@@ -0,0 +1,134 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) unde
cmccabe commented on code in PR #12513:
URL: https://github.com/apache/kafka/pull/12513#discussion_r949671940
##
metadata/src/main/java/org/apache/kafka/metadata/bootstrap/BootstrapMetadata.java:
##
@@ -0,0 +1,141 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under
cmccabe commented on code in PR #12513:
URL: https://github.com/apache/kafka/pull/12513#discussion_r949674532
##
metadata/src/main/java/org/apache/kafka/metadata/bootstrap/BootstrapMetadata.java:
##
@@ -0,0 +1,141 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under
hachikuji commented on code in PR #12538:
URL: https://github.com/apache/kafka/pull/12538#discussion_r949676740
##
core/src/test/java/kafka/testkit/KafkaClusterTestKit.java:
##
@@ -275,15 +275,15 @@ metaProperties, config, new MetadataRecordSerde(),
metadataPartition, KafkaRaft
cmccabe commented on code in PR #12513:
URL: https://github.com/apache/kafka/pull/12513#discussion_r949676920
##
metadata/src/main/java/org/apache/kafka/metadata/bootstrap/BootstrapMetadata.java:
##
@@ -0,0 +1,141 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under
hachikuji commented on code in PR #12538:
URL: https://github.com/apache/kafka/pull/12538#discussion_r949676740
##
core/src/test/java/kafka/testkit/KafkaClusterTestKit.java:
##
@@ -275,15 +275,15 @@ metaProperties, config, new MetadataRecordSerde(),
metadataPartition, KafkaRaft
cmccabe commented on code in PR #12513:
URL: https://github.com/apache/kafka/pull/12513#discussion_r949678938
##
metadata/src/main/java/org/apache/kafka/metadata/util/BatchFileReader.java:
##
@@ -0,0 +1,183 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or
cmccabe commented on code in PR #12513:
URL: https://github.com/apache/kafka/pull/12513#discussion_r949679883
##
metadata/src/main/java/org/apache/kafka/metadata/util/BatchFileReader.java:
##
@@ -0,0 +1,183 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or
cmccabe commented on code in PR #12513:
URL: https://github.com/apache/kafka/pull/12513#discussion_r949680410
##
metadata/src/main/java/org/apache/kafka/controller/QuorumController.java:
##
@@ -1118,6 +1059,65 @@ private void updateWriteOffset(long offset) {
}
}
[
https://issues.apache.org/jira/browse/KAFKA-10635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17581574#comment-17581574
]
Guozhang Wang commented on KAFKA-10635:
---
Hello [~nicktelford] Could you also paste
cmccabe commented on code in PR #12513:
URL: https://github.com/apache/kafka/pull/12513#discussion_r949685089
##
metadata/src/main/java/org/apache/kafka/controller/FeatureControlManager.java:
##
@@ -188,12 +182,16 @@ private ApiError updateFeature(
}
}
-
cmccabe commented on code in PR #12513:
URL: https://github.com/apache/kafka/pull/12513#discussion_r949686749
##
server-common/src/test/java/org/apache/kafka/server/common/MetadataVersionTest.java:
##
@@ -72,20 +71,18 @@
import static org.junit.jupiter.api.Assertions.assertTrue
cmccabe commented on code in PR #12513:
URL: https://github.com/apache/kafka/pull/12513#discussion_r949687350
##
metadata/src/main/java/org/apache/kafka/controller/LogReplayTracker.java:
##
@@ -0,0 +1,107 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or m
cmccabe commented on code in PR #12513:
URL: https://github.com/apache/kafka/pull/12513#discussion_r949687749
##
metadata/src/main/java/org/apache/kafka/controller/QuorumController.java:
##
@@ -1142,15 +1142,19 @@ private void renounce() {
purgatory.failAll(newNotCo
guozhangwang commented on PR #12512:
URL: https://github.com/apache/kafka/pull/12512#issuecomment-1220094009
Hello @vamossagar12 thanks for the PR.
I took another pass on KIP-691 and updated some exception cases in the wiki,
and I think we need to thoroughly go through them before we
cmccabe commented on code in PR #12513:
URL: https://github.com/apache/kafka/pull/12513#discussion_r949693026
##
metadata/src/test/java/org/apache/kafka/controller/FeatureControlManagerTest.java:
##
@@ -222,52 +227,130 @@ public void testFeatureControlIterator() throws
Exceptio
cmccabe commented on code in PR #12513:
URL: https://github.com/apache/kafka/pull/12513#discussion_r949693026
##
metadata/src/test/java/org/apache/kafka/controller/FeatureControlManagerTest.java:
##
@@ -222,52 +227,130 @@ public void testFeatureControlIterator() throws
Exceptio
cmccabe commented on code in PR #12513:
URL: https://github.com/apache/kafka/pull/12513#discussion_r949693455
##
metadata/src/test/java/org/apache/kafka/controller/FeatureControlManagerTest.java:
##
@@ -222,52 +227,130 @@ public void testFeatureControlIterator() throws
Exceptio
cmccabe commented on code in PR #12513:
URL: https://github.com/apache/kafka/pull/12513#discussion_r949694015
##
metadata/src/test/java/org/apache/kafka/controller/QuorumControllerTest.java:
##
@@ -952,6 +966,7 @@ public void testEarlyControllerResults() throws Throwable {
cmccabe commented on code in PR #12513:
URL: https://github.com/apache/kafka/pull/12513#discussion_r949694015
##
metadata/src/test/java/org/apache/kafka/controller/QuorumControllerTest.java:
##
@@ -952,6 +966,7 @@ public void testEarlyControllerResults() throws Throwable {
cmccabe commented on code in PR #12513:
URL: https://github.com/apache/kafka/pull/12513#discussion_r949693026
##
metadata/src/test/java/org/apache/kafka/controller/FeatureControlManagerTest.java:
##
@@ -222,52 +227,130 @@ public void testFeatureControlIterator() throws
Exceptio
cmccabe merged PR #12533:
URL: https://github.com/apache/kafka/pull/12533
--
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...@kafka.apache.
ijuma closed pull request #12500: MINOR: Remove spurious sleep in
ConsumerCoordinatorTest
URL: https://github.com/apache/kafka/pull/12500
--
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
showuon merged PR #12525:
URL: https://github.com/apache/kafka/pull/12525
--
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...@kafka.apache.
vamossagar12 commented on PR #12512:
URL: https://github.com/apache/kafka/pull/12512#issuecomment-1220313754
hello @guozhangwang Thanks for the note. I noticed that you had made some
changes to the KIP. This PR, I kept the changes focussed on send method but the
KIP covers all methods. Sure
RivenSun2 opened a new pull request, #12539:
URL: https://github.com/apache/kafka/pull/12539
Modify the error log level in SaslChannelBuilder
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build sta
85 matches
Mail list logo
