FrankYang0529 commented on PR #15821:
URL: https://github.com/apache/kafka/pull/15821#issuecomment-2080374723
Rely on https://github.com/apache/kafka/pull/15766.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
FrankYang0529 opened a new pull request, #15821:
URL: https://github.com/apache/kafka/pull/15821
By using `ClusterTestExtensions`, `ListConsumerGroupTest` get get away from
`KafkaServerTestHarness` dependency.
### Committer Checklist (excluded from commit message)
- [ ] Verify
[
https://issues.apache.org/jira/browse/KAFKA-14892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17841398#comment-17841398
]
Giuseppe Calabrese edited comment on KAFKA-14892 at 4/27/24 5:16 AM:
-
abhijeetk88 opened a new pull request, #15820:
URL: https://github.com/apache/kafka/pull/15820
*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
[
https://issues.apache.org/jira/browse/KAFKA-14892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17841398#comment-17841398
]
Giuseppe Calabrese commented on KAFKA-14892:
[~abhijeetkumar] [~chia7712] any ideas about
ableegoldman commented on code in PR #15819:
URL: https://github.com/apache/kafka/pull/15819#discussion_r1581729152
##
clients/src/main/java/org/apache/kafka/clients/GroupRebalanceConfig.java:
##
@@ -83,6 +84,14 @@ public GroupRebalanceConfig(AbstractConfig config,
brandboat commented on code in PR #15761:
URL: https://github.com/apache/kafka/pull/15761#discussion_r1581724166
##
core/src/test/java/kafka/test/ClusterConfigTest.java:
##
@@ -0,0 +1,93 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ *
brandboat commented on code in PR #15761:
URL: https://github.com/apache/kafka/pull/15761#discussion_r1581723855
##
core/src/test/java/kafka/test/ClusterConfigTest.java:
##
@@ -0,0 +1,93 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ *
[
https://issues.apache.org/jira/browse/KAFKA-16629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai reassigned KAFKA-16629:
--
Assignee: 黃竣陽 (was: Chia-Ping Tsai)
> add broker-related tests to
[
https://issues.apache.org/jira/browse/KAFKA-16629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17841391#comment-17841391
]
黃竣陽 commented on KAFKA-16629:
-
I will handle this issue.
> add broker-related tests to
artemlivshits commented on code in PR #15759:
URL: https://github.com/apache/kafka/pull/15759#discussion_r1581642961
##
core/src/test/java/kafka/server/integration/EligibleLeaderReplicasIntegrationTest.java:
##
@@ -0,0 +1,432 @@
+/*
+ * Licensed to the Apache Software
chia7712 commented on PR #15744:
URL: https://github.com/apache/kafka/pull/15744#issuecomment-2080249371
@mumrah I'm sorry but could you please fix the conflicts again?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
chia7712 commented on code in PR #15800:
URL: https://github.com/apache/kafka/pull/15800#discussion_r1581630236
##
core/src/test/java/kafka/test/ClusterTestExtensionsUnitTest.java:
##
@@ -0,0 +1,46 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+
mjsax commented on code in PR #15819:
URL: https://github.com/apache/kafka/pull/15819#discussion_r1581626291
##
clients/src/main/java/org/apache/kafka/clients/GroupRebalanceConfig.java:
##
@@ -83,6 +84,14 @@ public GroupRebalanceConfig(AbstractConfig config,
ProtocolType
[
https://issues.apache.org/jira/browse/KAFKA-6527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai resolved KAFKA-6527.
---
Resolution: Fixed
It is enabled by https://github.com/apache/kafka/pull/15796
> Transient
chia7712 commented on PR #13953:
URL: https://github.com/apache/kafka/pull/13953#issuecomment-2080246965
close as that is resolved by #15796
--
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
chia7712 closed pull request #13953: enable test, check if continues failing in
CI
URL: https://github.com/apache/kafka/pull/13953
--
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
[
https://issues.apache.org/jira/browse/KAFKA-6527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai reassigned KAFKA-6527:
-
Assignee: TaiJuWu
> Transient failure in
chia7712 merged PR #15796:
URL: https://github.com/apache/kafka/pull/15796
--
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:
chia7712 commented on PR #15796:
URL: https://github.com/apache/kafka/pull/15796#issuecomment-2080246076
Let's ship it to run it in the QA ASAP
--
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
chia7712 commented on PR #15645:
URL: https://github.com/apache/kafka/pull/15645#issuecomment-2080244534
@nizhikov I'm ok to accept this PR to be a java rewriting, and I file
https://issues.apache.org/jira/browse/KAFKA-16629 to add more tests in the
future. Hence, please fix comment
Chia-Ping Tsai created KAFKA-16629:
--
Summary: add broker-related tests to ConfigCommandIntegrationTest
Key: KAFKA-16629
URL: https://issues.apache.org/jira/browse/KAFKA-16629
Project: Kafka
chia7712 commented on code in PR #15645:
URL: https://github.com/apache/kafka/pull/15645#discussion_r1581621779
##
core/src/test/java/kafka/admin/ConfigCommandIntegrationTest.java:
##
@@ -0,0 +1,291 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+
chia7712 commented on code in PR #15766:
URL: https://github.com/apache/kafka/pull/15766#discussion_r1581608377
##
tools/src/test/java/org/apache/kafka/tools/consumer/group/ConsumerGroupExecutor.java:
##
@@ -0,0 +1,187 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
chia7712 commented on PR #15808:
URL: https://github.com/apache/kafka/pull/15808#issuecomment-2080226483
@m1a2st Could you please fix conflicts?
--
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
chia7712 commented on PR #15788:
URL: https://github.com/apache/kafka/pull/15788#issuecomment-2080225060
@johnnychhsu Could you please fix conflicts?
--
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
chia7712 merged PR #15807:
URL: https://github.com/apache/kafka/pull/15807
--
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:
chia7712 merged PR #15802:
URL: https://github.com/apache/kafka/pull/15802
--
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:
chia7712 merged PR #15775:
URL: https://github.com/apache/kafka/pull/15775
--
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:
chia7712 commented on code in PR #15761:
URL: https://github.com/apache/kafka/pull/15761#discussion_r1581597711
##
core/src/test/scala/integration/kafka/server/KafkaServerKRaftRegistrationTest.scala:
##
@@ -71,11 +72,16 @@ class KafkaServerKRaftRegistrationTest {
val
cmccabe merged PR #15809:
URL: https://github.com/apache/kafka/pull/15809
--
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:
[
https://issues.apache.org/jira/browse/KAFKA-16514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17841374#comment-17841374
]
A. Sophie Blee-Goldman commented on KAFKA-16514:
I opened a quick example PR to showcase
ableegoldman opened a new pull request, #15819:
URL: https://github.com/apache/kafka/pull/15819
POC for one option to fix the issue described in KAFKA-16514
This is definitely a hacky approach to introduce a backdoor solely for Kafka
Streams to implement its special close semantics.
[
https://issues.apache.org/jira/browse/KAFKA-16514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17841369#comment-17841369
]
A. Sophie Blee-Goldman commented on KAFKA-16514:
The immutable internal config thing is
jsancio commented on code in PR #15671:
URL: https://github.com/apache/kafka/pull/15671#discussion_r1581517439
##
raft/src/main/java/org/apache/kafka/raft/internals/History.java:
##
@@ -0,0 +1,119 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ *
lianetm commented on code in PR #15778:
URL: https://github.com/apache/kafka/pull/15778#discussion_r1581508063
##
tests/kafkatest/tests/client/consumer_test.py:
##
@@ -242,16 +242,15 @@ def test_static_consumer_bounce(self, clean_shutdown,
static_membership, bounce_
[
https://issues.apache.org/jira/browse/KAFKA-16628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans reassigned KAFKA-16628:
--
Assignee: Lianet Magrans
> Add system test for validating static consumer bounce and
Lianet Magrans created KAFKA-16628:
--
Summary: Add system test for validating static consumer bounce and
assignment when not eager
Key: KAFKA-16628
URL: https://issues.apache.org/jira/browse/KAFKA-16628
[
https://issues.apache.org/jira/browse/KAFKA-16528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans closed KAFKA-16528.
--
> Reset member heartbeat interval when request sent
>
jsancio commented on code in PR #15671:
URL: https://github.com/apache/kafka/pull/15671#discussion_r1581484869
##
raft/src/main/java/org/apache/kafka/raft/internals/History.java:
##
@@ -0,0 +1,119 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ *
dajac commented on PR #15818:
URL: https://github.com/apache/kafka/pull/15818#issuecomment-2080046398
@dongnuo123 Thanks for the patch. Could you also check if we have other
cases like this one:
jsancio commented on code in PR #15671:
URL: https://github.com/apache/kafka/pull/15671#discussion_r1581480096
##
raft/src/main/java/org/apache/kafka/raft/internals/VoterSet.java:
##
@@ -0,0 +1,327 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+
kirktrue commented on code in PR #15737:
URL: https://github.com/apache/kafka/pull/15737#discussion_r1581441497
##
tests/kafkatest/services/verifiable_consumer.py:
##
@@ -140,22 +150,32 @@ class
IncrementalAssignmentConsumerEventHandler(ConsumerEventHandler):
def
[
https://issues.apache.org/jira/browse/KAFKA-16609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True resolved KAFKA-16609.
---
Reviewer: Lucas Brutschy
Resolution: Fixed
> Update parse_describe_topic to support new topic
jsancio commented on code in PR #15671:
URL: https://github.com/apache/kafka/pull/15671#discussion_r1581410429
##
raft/src/main/java/org/apache/kafka/raft/internals/VoterSet.java:
##
@@ -0,0 +1,327 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+
nizhikov commented on PR #15645:
URL: https://github.com/apache/kafka/pull/15645#issuecomment-2079970499
@chia7712 CI looks good to me. Do you have any other comments?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
dongnuo123 opened a new pull request, #15818:
URL: https://github.com/apache/kafka/pull/15818
The patch adds a boolean attribute `replayRecords` that specifies whether
the records should be replayed. The default value is `appendFuture == null` so
no change is needed for the existing code.
jsancio commented on code in PR #15671:
URL: https://github.com/apache/kafka/pull/15671#discussion_r1581410429
##
raft/src/main/java/org/apache/kafka/raft/internals/VoterSet.java:
##
@@ -0,0 +1,327 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+
infantlikesprogramming commented on PR #15696:
URL: https://github.com/apache/kafka/pull/15696#issuecomment-2079935542
@chia7712 Thank you! The cluster that I deployed in Kraft (locally) consists
of 3 controllers and 4 brokers, using standard configurations from the
config/kraft folder.
jsancio commented on code in PR #15671:
URL: https://github.com/apache/kafka/pull/15671#discussion_r1581398905
##
raft/src/main/java/org/apache/kafka/raft/internals/VoterSet.java:
##
@@ -0,0 +1,327 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+
jsancio commented on code in PR #15671:
URL: https://github.com/apache/kafka/pull/15671#discussion_r1581392367
##
raft/src/main/java/org/apache/kafka/raft/internals/VoterSet.java:
##
@@ -0,0 +1,327 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+
jsancio commented on code in PR #15671:
URL: https://github.com/apache/kafka/pull/15671#discussion_r1581378400
##
raft/src/main/java/org/apache/kafka/raft/ReplicatedLog.java:
##
@@ -261,7 +260,7 @@ default long truncateToEndOffset(OffsetAndEpoch endOffset) {
* @param
[
https://issues.apache.org/jira/browse/KAFKA-16584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17841332#comment-17841332
]
Matthias J. Sax commented on KAFKA-16584:
-
There is an issue with creating new account:
[
https://issues.apache.org/jira/browse/KAFKA-16622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17841137#comment-17841137
]
Edoardo Comar edited comment on KAFKA-16622 at 4/26/24 6:04 PM:
if after
jsancio commented on code in PR #15671:
URL: https://github.com/apache/kafka/pull/15671#discussion_r1581343739
##
core/src/test/scala/unit/kafka/tools/DumpLogSegmentsTest.scala:
##
@@ -324,15 +323,11 @@ class DumpLogSegmentsTest {
val lastContainedLogTimestamp = 1
jsancio commented on code in PR #15671:
URL: https://github.com/apache/kafka/pull/15671#discussion_r1581332843
##
core/src/test/scala/unit/kafka/server/KafkaConfigTest.scala:
##
@@ -1341,29 +1340,25 @@ class KafkaConfigTest {
}
@Test
- def
jsancio commented on code in PR #15671:
URL: https://github.com/apache/kafka/pull/15671#discussion_r1581322854
##
core/src/test/scala/integration/kafka/server/RaftClusterSnapshotTest.scala:
##
@@ -87,9 +85,12 @@ class RaftClusterSnapshotTest {
// Check that we can
jsancio commented on code in PR #15671:
URL: https://github.com/apache/kafka/pull/15671#discussion_r1581315479
##
clients/src/test/java/org/apache/kafka/common/record/ControlRecordTypeTest.java:
##
@@ -45,4 +45,58 @@ public void testParseUnknownVersion() {
lucasbru commented on code in PR #15778:
URL: https://github.com/apache/kafka/pull/15778#discussion_r1581306529
##
tests/kafkatest/tests/client/consumer_test.py:
##
@@ -242,16 +242,15 @@ def test_static_consumer_bounce(self, clean_shutdown,
static_membership, bounce_
kamalcph opened a new pull request, #15817:
URL: https://github.com/apache/kafka/pull/15817
When there are overlapping segments in the remote storage, then the deletion
may fail to remove the segments due to `isRemoteSegmentWithinLeaderEpochs`
check. Once the deletion starts to fail for a
[
https://issues.apache.org/jira/browse/KAFKA-15342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17841294#comment-17841294
]
Chia-Ping Tsai commented on KAFKA-15342:
not sure the benefit of having unit test and
dongnuo123 opened a new pull request, #15816:
URL: https://github.com/apache/kafka/pull/15816
We are seeing flaky test in
`testConsumerGroupHeartbeatWithStableClassicGroup` where the error is caused by
the different ordering in the expected and actual values. The patch sorts the
topic
jsancio commented on code in PR #15671:
URL: https://github.com/apache/kafka/pull/15671#discussion_r1581234346
##
clients/src/main/resources/common/message/VotersRecord.json:
##
@@ -0,0 +1,47 @@
+// Licensed to the Apache Software Foundation (ASF) under one or more
+//
jsancio commented on code in PR #15671:
URL: https://github.com/apache/kafka/pull/15671#discussion_r1580159998
##
clients/src/main/resources/common/message/VotersRecord.json:
##
@@ -0,0 +1,47 @@
+// Licensed to the Apache Software Foundation (ASF) under one or more
+//
lianetm commented on code in PR #15778:
URL: https://github.com/apache/kafka/pull/15778#discussion_r1581203195
##
tests/kafkatest/tests/client/consumer_test.py:
##
@@ -242,16 +242,15 @@ def test_static_consumer_bounce(self, clean_shutdown,
static_membership, bounce_
rreddy-22 commented on code in PR #15785:
URL: https://github.com/apache/kafka/pull/15785#discussion_r1581140616
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/consumer/ConsumerGroup.java:
##
@@ -966,6 +987,23 @@ private static void
rreddy-22 commented on code in PR #15785:
URL: https://github.com/apache/kafka/pull/15785#discussion_r1581134610
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/consumer/ConsumerGroup.java:
##
@@ -620,9 +637,10 @@ public Map
computeSubscriptionMetadata(
rreddy-22 commented on code in PR #15785:
URL: https://github.com/apache/kafka/pull/15785#discussion_r1581132398
##
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/assignor/ServerSideAssignorBenchmark.java:
##
@@ -204,7 +198,7 @@ private void createAssignmentSpec() {
msn-tldr commented on code in PR #14111:
URL: https://github.com/apache/kafka/pull/14111#discussion_r1581106940
##
clients/src/main/java/org/apache/kafka/clients/producer/internals/ProducerBatch.java:
##
@@ -384,6 +389,32 @@ int attempts() {
return attempts.get();
[
https://issues.apache.org/jira/browse/KAFKA-14892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17841254#comment-17841254
]
Giuseppe Calabrese commented on KAFKA-14892:
Hi, I'm new in ASF.
I wonder if this ticket
chia7712 commented on PR #15815:
URL: https://github.com/apache/kafka/pull/15815#issuecomment-2079444105
We are doing the migration so can this PR get pending before we see more use
cases?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
[
https://issues.apache.org/jira/browse/KAFKA-16611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai reassigned KAFKA-16611:
--
Assignee: PoAn Yang (was: Chia-Ping Tsai)
> Consider adding test name to
[
https://issues.apache.org/jira/browse/KAFKA-15838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison updated KAFKA-15838:
---
Component/s: connect
> [Connect] ExtractField and InsertField NULL Values are replaced by
dajac commented on PR #15448:
URL: https://github.com/apache/kafka/pull/15448#issuecomment-2079403659
I think that we won't add this one in the end. Closing it.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
dajac commented on PR #15286:
URL: https://github.com/apache/kafka/pull/15286#issuecomment-2079402203
@rreddy-22 Do we still need this one?
--
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
dajac closed pull request #15448: KAFKA-16317: Add event process rate in
GroupCoordinatorRuntimeMetrics
URL: https://github.com/apache/kafka/pull/15448
--
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
dajac commented on PR #15329:
URL: https://github.com/apache/kafka/pull/15329#issuecomment-2079402641
I think that we don't need this anymore. 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 above to
dajac closed pull request #15329: KIP848- Add JMH Benchmarks for Client And
Server Side Assignors
URL: https://github.com/apache/kafka/pull/15329
--
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
dajac closed pull request #15268: [Draft] Join, Sync, Heartbeat during Migration
URL: https://github.com/apache/kafka/pull/15268
--
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.
dajac commented on PR #15268:
URL: https://github.com/apache/kafka/pull/15268#issuecomment-2079401308
I think that we don't need this anymore. 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 above to
tinaselenge commented on code in PR #15377:
URL: https://github.com/apache/kafka/pull/15377#discussion_r1581029496
##
core/src/test/scala/integration/kafka/api/SslAdminIntegrationTest.scala:
##
@@ -259,4 +275,22 @@ class SslAdminIntegrationTest extends
tinaselenge commented on code in PR #15377:
URL: https://github.com/apache/kafka/pull/15377#discussion_r1581029496
##
core/src/test/scala/integration/kafka/api/SslAdminIntegrationTest.scala:
##
@@ -259,4 +275,22 @@ class SslAdminIntegrationTest extends
mimaison merged PR #15805:
URL: https://github.com/apache/kafka/pull/15805
--
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:
dongnuo123 commented on code in PR #15798:
URL: https://github.com/apache/kafka/pull/15798#discussion_r1581026465
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorService.java:
##
@@ -1122,4 +1122,27 @@ private OUT handleOperationException(
dajac commented on code in PR #15798:
URL: https://github.com/apache/kafka/pull/15798#discussion_r1580929744
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java:
##
@@ -1413,6 +1506,243 @@ private
CoordinatorResult consumerGr
FrankYang0529 opened a new pull request, #15815:
URL: https://github.com/apache/kafka/pull/15815
Sometimes we close the admin created by `createAdminClient`, and sometimes
we don't. That is not a true problem since the `ClusterInstance` will call
`close` when stopping.
However, that
[
https://issues.apache.org/jira/browse/KAFKA-16611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17841193#comment-17841193
]
PoAn Yang commented on KAFKA-16611:
---
Hi [~chia7712], I'm interested in this issue. May I take it?
dajac commented on code in PR #15798:
URL: https://github.com/apache/kafka/pull/15798#discussion_r1580920772
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java:
##
@@ -1288,25 +1396,10 @@ private
CoordinatorResult consumerGr
bachmanity1 commented on PR #15475:
URL: https://github.com/apache/kafka/pull/15475#issuecomment-2079216075
Hi @mimaison, would you mind taking a look at the KIP and sharing your vote
on it? Thank you!
--
This is an automated message from the Apache Git Service.
To respond to the
cadonna commented on code in PR #15640:
URL: https://github.com/apache/kafka/pull/15640#discussion_r1580785461
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumer.java:
##
@@ -1169,8 +1129,7 @@ private Map
beginningOrEndOffset(Collection
appchemist commented on code in PR #15647:
URL: https://github.com/apache/kafka/pull/15647#discussion_r1580504115
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractFetch.java:
##
@@ -200,6 +200,9 @@ protected void handleFetchSuccess(final Node
[
https://issues.apache.org/jira/browse/KAFKA-16622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17841137#comment-17841137
]
Edoardo Comar edited comment on KAFKA-16622 at 4/26/24 10:40 AM:
-
if
[
https://issues.apache.org/jira/browse/KAFKA-16622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17841137#comment-17841137
]
Edoardo Comar commented on KAFKA-16622:
---
if after the consumer reaches 1 and the 1st
[
https://issues.apache.org/jira/browse/KAFKA-16622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17841134#comment-17841134
]
Edoardo Comar edited comment on KAFKA-16622 at 4/26/24 10:18 AM:
-
Hi
[
https://issues.apache.org/jira/browse/KAFKA-16622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17841134#comment-17841134
]
Edoardo Comar edited comment on KAFKA-16622 at 4/26/24 10:17 AM:
-
Hi
[
https://issues.apache.org/jira/browse/KAFKA-16622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17841134#comment-17841134
]
Edoardo Comar edited comment on KAFKA-16622 at 4/26/24 10:17 AM:
-
Hi
[
https://issues.apache.org/jira/browse/KAFKA-16622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17841134#comment-17841134
]
Edoardo Comar edited comment on KAFKA-16622 at 4/26/24 10:16 AM:
-
Hi
[
https://issues.apache.org/jira/browse/KAFKA-16622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17841134#comment-17841134
]
Edoardo Comar edited comment on KAFKA-16622 at 4/26/24 10:15 AM:
-
Hi
[
https://issues.apache.org/jira/browse/KAFKA-16622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17841134#comment-17841134
]
Edoardo Comar edited comment on KAFKA-16622 at 4/26/24 10:13 AM:
-
Hi
[
https://issues.apache.org/jira/browse/KAFKA-16622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17841134#comment-17841134
]
Edoardo Comar edited comment on KAFKA-16622 at 4/26/24 10:12 AM:
-
Hi
1 - 100 of 137 matches
Mail list logo
