Hangleton commented on code in PR #13240:
URL: https://github.com/apache/kafka/pull/13240#discussion_r1185779424
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinatorTest.java:
##
@@ -2707,11 +2742,271 @@ public void testCommitOffsetUnknownMemb
[
https://issues.apache.org/jira/browse/KAFKA-14805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen updated KAFKA-14805:
--
Fix Version/s: (was: 3.4.1)
> KRaft Controller shouldn't allow metadata updates before migration s
[
https://issues.apache.org/jira/browse/KAFKA-14963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen resolved KAFKA-14963.
---
Resolution: Fixed
> Incorrect partition count metrics for kraft controllers
> --
divijvaidya commented on PR #13662:
URL: https://github.com/apache/kafka/pull/13662#issuecomment-1535880466
@bmscomp this is a nice PR and I support it. I opened the other one (
https://github.com/apache/kafka/pull/13673 ) for minor versions upgrades
because minor versions have a lower ris
divijvaidya commented on PR #13421:
URL: https://github.com/apache/kafka/pull/13421#issuecomment-1535884087
@hudeqi thanks for reminding me about this. I will review it next week.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitH
[
https://issues.apache.org/jira/browse/KAFKA-14514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot reassigned KAFKA-14514:
---
Assignee: David Jacot
> Implement range broker side assignor
>
[
https://issues.apache.org/jira/browse/KAFKA-14515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot reassigned KAFKA-14515:
---
Assignee: David Jacot
> Implement uniform broker side assignor
> --
[
https://issues.apache.org/jira/browse/KAFKA-14501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot reassigned KAFKA-14501:
---
Assignee: Jeff Kim
> Implement Heartbeat API
> ---
>
>
[
https://issues.apache.org/jira/browse/KAFKA-14502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot reassigned KAFKA-14502:
---
Assignee: Jeff Kim
> Implement LeaveGroup API
>
>
>
divijvaidya commented on code in PR #13312:
URL: https://github.com/apache/kafka/pull/13312#discussion_r1185820116
##
clients/src/test/java/org/apache/kafka/common/utils/ByteUtilsTest.java:
##
@@ -241,6 +244,119 @@ public void testDouble() throws IOException {
assertDou
divijvaidya commented on code in PR #13312:
URL: https://github.com/apache/kafka/pull/13312#discussion_r1185820299
##
clients/src/test/java/org/apache/kafka/common/utils/ByteUtilsTest.java:
##
@@ -241,6 +244,119 @@ public void testDouble() throws IOException {
assertDou
cmccabe merged PR #13461:
URL: https://github.com/apache/kafka/pull/13461
--
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.
cmccabe commented on PR #12331:
URL: https://github.com/apache/kafka/pull/12331#issuecomment-1535924639
> @Hangleton : Agree that this change should be ideally confined to the
Windows platform w/o any code change for others.
Yeah. To be totally clear, it's OK to change the main code p
bmscomp commented on PR #13662:
URL: https://github.com/apache/kafka/pull/13662#issuecomment-1535937778
@divijvaidya I get your point, thanks so much for those explanations
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
urbandan commented on code in PR #13591:
URL: https://github.com/apache/kafka/pull/13591#discussion_r1185797643
##
clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java:
##
@@ -424,6 +477,11 @@ ProducerIdAndEpoch producerIdAndEpoch() {
}
clolov commented on code in PR #13240:
URL: https://github.com/apache/kafka/pull/13240#discussion_r1185861417
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinatorTest.java:
##
@@ -2707,11 +2742,271 @@ public void testCommitOffsetUnknownMemberI
divijvaidya commented on code in PR #13676:
URL: https://github.com/apache/kafka/pull/13676#discussion_r1185859941
##
settings.gradle:
##
@@ -13,6 +13,38 @@
// See the License for the specific language governing permissions and
// limitations under the License.
+plugins {
+
huxiangquan commented on PR #12331:
URL: https://github.com/apache/kafka/pull/12331#issuecomment-1536010891
Can someone help kafka on windows , please?
Two years have passed ！
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
vamossagar12 commented on code in PR #11433:
URL: https://github.com/apache/kafka/pull/11433#discussion_r1185968862
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java:
##
@@ -262,6 +262,42 @@ private void closeDirtyAndRevive(final Collection
vamossagar12 commented on code in PR #11433:
URL: https://github.com/apache/kafka/pull/11433#discussion_r1185970601
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java:
##
@@ -342,7 +342,19 @@ public void handleAssignment(final Map> activeTasks
vamossagar12 commented on code in PR #11433:
URL: https://github.com/apache/kafka/pull/11433#discussion_r1185973531
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java:
##
@@ -342,7 +342,19 @@ public void handleAssignment(final Map> activeTasks
vamossagar12 commented on code in PR #11433:
URL: https://github.com/apache/kafka/pull/11433#discussion_r1185974966
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java:
##
@@ -342,7 +342,19 @@ public void handleAssignment(final Map> activeTasks
vamossagar12 commented on code in PR #11433:
URL: https://github.com/apache/kafka/pull/11433#discussion_r1185975845
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java:
##
@@ -342,7 +342,18 @@ public void handleAssignment(final Map> activeTasks
vamossagar12 commented on code in PR #11433:
URL: https://github.com/apache/kafka/pull/11433#discussion_r1185978385
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java:
##
@@ -342,7 +342,19 @@ public void handleAssignment(final Map> activeTasks
vamossagar12 commented on code in PR #11433:
URL: https://github.com/apache/kafka/pull/11433#discussion_r1185979279
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java:
##
@@ -342,7 +342,18 @@ public void handleAssignment(final Map> activeTasks
chia7712 commented on PR #13659:
URL: https://github.com/apache/kafka/pull/13659#issuecomment-1536128806
failed tests are unrelated. Will merge it later
--
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
rohits64 opened a new pull request, #13677:
URL: https://github.com/apache/kafka/pull/13677
*More detailed description of your change,
if necessary. The PR title and PR message become
the squashed commit message, so use a separate
comment to ping reviewers.*
*Summary of testin
divijvaidya commented on code in PR #13673:
URL: https://github.com/apache/kafka/pull/13673#discussion_r1185999578
##
gradle/dependencies.gradle:
##
@@ -142,7 +142,7 @@ libs += [
apachedsMavibotPartition:
"org.apache.directory.server:apacheds-mavibot-partition:$versions.apac
divijvaidya commented on code in PR #13673:
URL: https://github.com/apache/kafka/pull/13673#discussion_r1185999578
##
gradle/dependencies.gradle:
##
@@ -142,7 +142,7 @@ libs += [
apachedsMavibotPartition:
"org.apache.directory.server:apacheds-mavibot-partition:$versions.apac
dajac merged PR #13623:
URL: https://github.com/apache/kafka/pull/13623
--
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
[
https://issues.apache.org/jira/browse/KAFKA-14926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot resolved KAFKA-14926.
-
Resolution: Fixed
> Remove metrics on Log Cleaner shutdown
> ---
showuon commented on PR #13515:
URL: https://github.com/apache/kafka/pull/13515#issuecomment-1536153857
Retriggering the CI build since it failed with some infra's issue.
https://ci-builds.apache.org/job/Kafka/job/kafka-pr/job/PR-13515/8/
--
This is an automated message from the Apache
showuon commented on PR #13660:
URL: https://github.com/apache/kafka/pull/13660#issuecomment-1536155265
Retriggering the CI build since it failed with infra's issue.
https://ci-builds.apache.org/job/Kafka/job/kafka-pr/job/PR-13660/3/
--
This is an automated message from the Apache Git S
divijvaidya commented on PR #13623:
URL: https://github.com/apache/kafka/pull/13623#issuecomment-1536155781
Thank you @dajac. Appreciate your time and patience on this PR. 🙏
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
showuon commented on PR #13312:
URL: https://github.com/apache/kafka/pull/13312#issuecomment-1536156206
Failed tests are unrelated:
```
Build / JDK 8 and Scala 2.12 /
org.apache.kafka.clients.consumer.internals.AbstractCoordinatorTest.testBackoffAndRetryUponRetriableError()
showuon merged PR #13312:
URL: https://github.com/apache/kafka/pull/13312
--
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.
divijvaidya commented on PR #13312:
URL: https://github.com/apache/kafka/pull/13312#issuecomment-1536165039
Thank you @showuon and @ijuma for your time and patience in this review 🙏
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Git
rohits64 commented on PR #13677:
URL: https://github.com/apache/kafka/pull/13677#issuecomment-1536165839
Duplicate
--
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 unsubs
rohits64 closed pull request #13677: KAFKA-14401 with test [WIP]
URL: https://github.com/apache/kafka/pull/13677
--
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,
Hendrik Jan van Randen created KAFKA-14968:
--
Summary: Consumer Notification Callback
Key: KAFKA-14968
URL: https://issues.apache.org/jira/browse/KAFKA-14968
Project: Kafka
Issue Type
[
https://issues.apache.org/jira/browse/KAFKA-14968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hendrik Jan van Randen reassigned KAFKA-14968:
--
Assignee: Hendrik Jan van Randen
> Consumer Notification Callback
> -
[
https://issues.apache.org/jira/browse/KAFKA-14968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hendrik Jan van Randen updated KAFKA-14968:
---
Description:
We want to use Kafka for all the communication between our serv
Divij Vaidya created KAFKA-14969:
Summary: Upgrade Mockito to 4.11.0
Key: KAFKA-14969
URL: https://issues.apache.org/jira/browse/KAFKA-14969
Project: Kafka
Issue Type: Improvement
C
lucasbru commented on code in PR #11433:
URL: https://github.com/apache/kafka/pull/11433#discussion_r1186098795
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java:
##
@@ -342,7 +342,19 @@ public void handleAssignment(final Map> activeTasks,
[
https://issues.apache.org/jira/browse/KAFKA-14969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17719865#comment-17719865
]
Ismael Juma commented on KAFKA-14969:
-
I thought we should go straight to 5.x when w
[
https://issues.apache.org/jira/browse/KAFKA-14901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17719868#comment-17719868
]
Mickael Maison commented on KAFKA-14901:
[~gharris1727] Do you think this is a b
divijvaidya commented on PR #13670:
URL: https://github.com/apache/kafka/pull/13670#issuecomment-1536300068
The failing tests are unrelated:
```
Build / JDK 8 and Scala 2.12 /
testElectUncleanLeadersForOnePartition(String).quorum=kraft –
kafka.api.PlaintextAdminIntegrationTest
26s
[
https://issues.apache.org/jira/browse/KAFKA-14084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17719877#comment-17719877
]
Mickael Maison commented on KAFKA-14084:
[~cmccabe]/[~pprovenzano] What is the s
[
https://issues.apache.org/jira/browse/KAFKA-14805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17719878#comment-17719878
]
Mickael Maison commented on KAFKA-14805:
[~mumrah] The associated PR is merged,
[
https://issues.apache.org/jira/browse/KAFKA-14918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17719880#comment-17719880
]
Mickael Maison commented on KAFKA-14918:
Ping [~mumrah] can you share an update?
[
https://issues.apache.org/jira/browse/KAFKA-14840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17719881#comment-17719881
]
Mickael Maison commented on KAFKA-14840:
[~mumrah] The associated PR is merged,
[
https://issues.apache.org/jira/browse/KAFKA-14831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17719885#comment-17719885
]
Mickael Maison commented on KAFKA-14831:
Is this near completion? If not I'll mo
[
https://issues.apache.org/jira/browse/KAFKA-14698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17719886#comment-17719886
]
Mickael Maison commented on KAFKA-14698:
[~akhileshchg]/[~mumrah] What's the sta
[
https://issues.apache.org/jira/browse/KAFKA-14084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17719899#comment-17719899
]
Proven Provenzano commented on KAFKA-14084:
---
[~mimaison] The last commit for S
[
https://issues.apache.org/jira/browse/KAFKA-14859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Proven Provenzano resolved KAFKA-14859.
---
Resolution: Fixed
Merged into trunk and 3.5
> Support SCRAM ZK to KRaft Migration
>
clayburn commented on code in PR #13676:
URL: https://github.com/apache/kafka/pull/13676#discussion_r1186202287
##
settings.gradle:
##
@@ -13,6 +13,38 @@
// See the License for the specific language governing permissions and
// limitations under the License.
+plugins {
+
clayburn commented on code in PR #13676:
URL: https://github.com/apache/kafka/pull/13676#discussion_r1186205824
##
settings.gradle:
##
@@ -13,6 +13,38 @@
// See the License for the specific language governing permissions and
// limitations under the License.
+plugins {
+
clayburn commented on PR #13676:
URL: https://github.com/apache/kafka/pull/13676#issuecomment-1536412348
> Thank you for the contribution.
>
> It would be super helpful (perhaps outside of this PR) if you could add a
section in our documentation [1] on how to monitor the result of the
[
https://issues.apache.org/jira/browse/KAFKA-14084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17719922#comment-17719922
]
Mickael Maison commented on KAFKA-14084:
So I think we could close this ticket,
vvcephei commented on code in PR #13633:
URL: https://github.com/apache/kafka/pull/13633#discussion_r1186269574
##
build.gradle:
##
@@ -2057,6 +2057,7 @@ project(':streams') {
srcJar.dependsOn 'processMessages'
javadoc {
+options.memberLevel = JavadocMemberLevel.PUBL
vvcephei commented on PR #13633:
URL: https://github.com/apache/kafka/pull/13633#issuecomment-1536478379
Actually, @mjsax , I do have one question before merging: Are there classes
that are meant to be overridden by users? If so, should their protected members
be documented?
--
This is a
[
https://issues.apache.org/jira/browse/KAFKA-14831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14831:
--
Reviewer: Justine Olshan
> Illegal state errors should be fatal in transactional producer
> --
[
https://issues.apache.org/jira/browse/KAFKA-14831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17719931#comment-17719931
]
Kirk True commented on KAFKA-14831:
---
[~jolshan] has been providing most of the feedbac
[
https://issues.apache.org/jira/browse/KAFKA-14831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14831:
--
Description: In KAFKA-14830, the producer hit an illegal state error. The
error was propagated to the
[
https://issues.apache.org/jira/browse/KAFKA-14961?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17719933#comment-17719933
]
Kirk True commented on KAFKA-14961:
---
cc [~pnee] [~lianetm]
> DefaultBackgroundThread
jolshan commented on code in PR #13638:
URL: https://github.com/apache/kafka/pull/13638#discussion_r1186307624
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/consumer/CurrentAssignmentBuilder.java:
##
@@ -0,0 +1,445 @@
+/*
+ * Licensed to the Apache Softwa
jolshan commented on PR #13591:
URL: https://github.com/apache/kafka/pull/13591#issuecomment-1536545551
https://github.com/apache/kafka/commit/ea81e99e5980c807414651034a8c60426a158ca4
added TransitionToUnitialized. Can we confirm this has the behavior we expect?
I believe this would count
[
https://issues.apache.org/jira/browse/KAFKA-14831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17719941#comment-17719941
]
Justine Olshan commented on KAFKA-14831:
I guess I had assumed we missed the cod
mjsax commented on code in PR #13633:
URL: https://github.com/apache/kafka/pull/13633#discussion_r1186357597
##
build.gradle:
##
@@ -2057,6 +2057,7 @@ project(':streams') {
srcJar.dependsOn 'processMessages'
javadoc {
+options.memberLevel = JavadocMemberLevel.PUBLIC
mjsax commented on PR #13633:
URL: https://github.com/apache/kafka/pull/13633#issuecomment-1536581114
Thank @vvcephei -- for K14839 in particular, it's nothing users should
overwrite, in fact, they should not even extend the class in question at all.
I did not double check in general
chia7712 merged PR #13659:
URL: https://github.com/apache/kafka/pull/13659
--
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
[
https://issues.apache.org/jira/browse/KAFKA-14791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrew Grant reassigned KAFKA-14791:
Assignee: Andrew Grant
> Create a builder class for PartitionRegistration
> -
Proven Provenzano created KAFKA-14970:
-
Summary: Dual write mode testing for SCRAM and Quota
Key: KAFKA-14970
URL: https://issues.apache.org/jira/browse/KAFKA-14970
Project: Kafka
Issue T
[
https://issues.apache.org/jira/browse/KAFKA-14084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Proven Provenzano resolved KAFKA-14084.
---
Resolution: Fixed
SCRAM support in KRaft is implemented.
Test of SCRAM authorizatio
[
https://issues.apache.org/jira/browse/KAFKA-14831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14831:
--
Fix Version/s: 3.6.0
(was: 3.5.0)
> Illegal state errors should be fatal in tra
[
https://issues.apache.org/jira/browse/KAFKA-14831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17719988#comment-17719988
]
Kirk True commented on KAFKA-14831:
---
Sounds good, [~jolshan]. I updated the fix versio
[
https://issues.apache.org/jira/browse/KAFKA-14831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17719992#comment-17719992
]
Mickael Maison commented on KAFKA-14831:
Thanks!
> Illegal state errors should
[
https://issues.apache.org/jira/browse/KAFKA-14084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17719993#comment-17719993
]
Mickael Maison commented on KAFKA-14084:
Thanks!
> Support SCRAM when using KRa
vvcephei commented on PR #13664:
URL: https://github.com/apache/kafka/pull/13664#issuecomment-1536827381
I'm re-running the tests to see if we can get a green build.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
vvcephei commented on PR #13455:
URL: https://github.com/apache/kafka/pull/13455#issuecomment-1536829632
There were a lot of test failures. I just triggered it again.
It doesn't seem implausible that changing the MockConsumer could cause other
tests to fail, but I didn't look at wheth
junrao commented on code in PR #13503:
URL: https://github.com/apache/kafka/pull/13503#discussion_r1186548617
##
core/src/test/scala/unit/kafka/server/ReplicaFetcherTierStateMachineTest.scala:
##
@@ -0,0 +1,135 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under on
[
https://issues.apache.org/jira/browse/KAFKA-14968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hendrik Jan van Randen updated KAFKA-14968:
---
Description:
We want to use Kafka for all the communication between our serv
wenbingshen closed pull request #10625: MINOR: Fix error log for bounce broker
URL: https://github.com/apache/kafka/pull/10625
--
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.
T
wenbingshen opened a new pull request, #10625:
URL: https://github.com/apache/kafka/pull/10625
bounce leader broker for topic partition was mistakenly log as a follower
broker
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Ve
erikvanoosten opened a new pull request, #13678:
URL: https://github.com/apache/kafka/pull/13678
The contract for commitSync() guarantees that the callbacks for all prior
async commits will be invoked before it (successfully?) returns. Prior to this
change the contract could be violated if
[
https://issues.apache.org/jira/browse/KAFKA-10337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17720113#comment-17720113
]
Erik van Oosten commented on KAFKA-10337:
-
Opened [~thomaslee] 's PR again: http
[
https://issues.apache.org/jira/browse/KAFKA-10337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17720114#comment-17720114
]
Erik van Oosten commented on KAFKA-10337:
-
[~thomaslee] when we use commitAsync
erikvanoosten commented on PR #13678:
URL: https://github.com/apache/kafka/pull/13678#issuecomment-1537071678
This PR is a copy of https://github.com/apache/kafka/pull/9111 so all
credits go to @thomaslee.
--
This is an automated message from the Apache Git Service.
To respond to the mess
88 matches
Mail list logo
