lucasbru merged PR #15742:
URL: https://github.com/apache/kafka/pull/15742
--
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:
fvaleri commented on code in PR #14847:
URL: https://github.com/apache/kafka/pull/14847#discussion_r1580741403
##
tools/src/test/java/org/apache/kafka/tools/StorageToolTest.java:
##
@@ -0,0 +1,517 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ *
FrankYang0529 commented on code in PR #15802:
URL: https://github.com/apache/kafka/pull/15802#discussion_r1580759879
##
tools/src/test/java/org/apache/kafka/tools/consumer/group/DeleteOffsetsConsumerGroupCommandIntegrationTest.java:
##
@@ -169,20 +201,22 @@ private static
fvaleri commented on code in PR #14847:
URL: https://github.com/apache/kafka/pull/14847#discussion_r1580759331
##
tools/src/main/java/org/apache/kafka/tools/StorageTool.java:
##
@@ -0,0 +1,555 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ *
[
https://issues.apache.org/jira/browse/KAFKA-16621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuzhou resolved KAFKA-16621.
Resolution: Not A Bug
Fixed in KAFKA-15182: Normalize source connector offsets before invoking
[
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
soarez commented on code in PR #15690:
URL: https://github.com/apache/kafka/pull/15690#discussion_r1580567800
##
core/src/main/java/kafka/server/TierStateMachine.java:
##
@@ -54,5 +180,109 @@ PartitionFetchState start(TopicPartition topicPartition,
* @return the new
[
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
lucasbru merged PR #15737:
URL: https://github.com/apache/kafka/pull/15737
--
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:
nizhikov commented on code in PR #15645:
URL: https://github.com/apache/kafka/pull/15645#discussion_r1580711745
##
core/src/test/java/kafka/admin/ConfigCommandIntegrationTest.java:
##
@@ -0,0 +1,291 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+
nizhikov commented on code in PR #15645:
URL: https://github.com/apache/kafka/pull/15645#discussion_r1580711310
##
core/src/test/java/kafka/admin/ConfigCommandIntegrationTest.java:
##
@@ -0,0 +1,291 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+
FrankYang0529 commented on code in PR #15802:
URL: https://github.com/apache/kafka/pull/15802#discussion_r1580755873
##
tools/src/test/java/org/apache/kafka/tools/consumer/group/DeleteOffsetsConsumerGroupCommandIntegrationTest.java:
##
@@ -91,65 +91,97 @@ public void
AndrewJSchofield commented on code in PR #15803:
URL: https://github.com/apache/kafka/pull/15803#discussion_r1580787182
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumerTest.java:
##
@@ -1789,6 +1791,33 @@ public void
[
https://issues.apache.org/jira/browse/KAFKA-16622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Edoardo Comar updated KAFKA-16622:
--
Attachment: connect.log.2024-04-26-10.zip
> Mirromaker2 first Checkpoint not emitted until
[
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
dopuskh3 opened a new pull request, #15813:
URL: https://github.com/apache/kafka/pull/15813
*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
dopuskh3 closed pull request #15813: Add retriable tag to ErrorsPerSec JMX
metric
URL: https://github.com/apache/kafka/pull/15813
--
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
fvaleri commented on code in PR #14847:
URL: https://github.com/apache/kafka/pull/14847#discussion_r1580757743
##
metadata/src/main/java/org/apache/kafka/metadata/properties/MetaProperties.java:
##
@@ -47,7 +47,7 @@ public final class MetaProperties {
/**
* The
[
https://issues.apache.org/jira/browse/KAFKA-16622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17841134#comment-17841134
]
Edoardo Comar commented on KAFKA-16622:
---
Hi [~gharris1727]
The task did not restart. Here are the
[
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
cadonna merged PR #15698:
URL: https://github.com/apache/kafka/pull/15698
--
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:
nizhikov commented on code in PR #15645:
URL: https://github.com/apache/kafka/pull/15645#discussion_r1580728829
##
core/src/test/java/kafka/admin/ConfigCommandIntegrationTest.java:
##
@@ -0,0 +1,291 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+
[
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
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=17841134#comment-17841134
]
Edoardo Comar edited comment on KAFKA-16622 at 4/26/24 10:15 AM:
-
Hi
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
appchemist commented on code in PR #15647:
URL: https://github.com/apache/kafka/pull/15647#discussion_r1580510829
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/FetchCollector.java:
##
@@ -327,21 +327,27 @@ private void handleInitializeErrors(final
[
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
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
[
https://issues.apache.org/jira/browse/KAFKA-16585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17841079#comment-17841079
]
Stanislav Spiridonov commented on KAFKA-16585:
--
Ok. Let's not make simple things
brandboat commented on code in PR #15761:
URL: https://github.com/apache/kafka/pull/15761#discussion_r1580532456
##
core/src/test/java/kafka/test/ClusterTestExtensionsTest.java:
##
@@ -48,14 +51,18 @@ public class ClusterTestExtensionsTest {
// Static methods can
brandboat commented on code in PR #15761:
URL: https://github.com/apache/kafka/pull/15761#discussion_r1580532188
##
core/src/test/java/kafka/test/ClusterConfig.java:
##
@@ -139,28 +151,38 @@ public Map nameTags() {
return tags;
}
-public ClusterConfig
appchemist commented on code in PR #15647:
URL: https://github.com/apache/kafka/pull/15647#discussion_r1580510829
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/FetchCollector.java:
##
@@ -327,21 +327,27 @@ private void handleInitializeErrors(final
abhijeetk88 commented on code in PR #15625:
URL: https://github.com/apache/kafka/pull/15625#discussion_r1580545776
##
core/src/main/java/kafka/log/remote/quota/RLMQuotaManager.java:
##
@@ -0,0 +1,119 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
chia7712 commented on code in PR #15761:
URL: https://github.com/apache/kafka/pull/15761#discussion_r1580513112
##
core/src/test/scala/integration/kafka/zk/ZkMigrationIntegrationTest.scala:
##
@@ -57,16 +57,18 @@ import org.slf4j.{Logger, LoggerFactory}
import java.util
chia7712 commented on code in PR #15761:
URL: https://github.com/apache/kafka/pull/15761#discussion_r1580535934
##
core/src/test/java/kafka/test/ClusterConfig.java:
##
@@ -139,28 +151,38 @@ public Map nameTags() {
return tags;
}
-public ClusterConfig
chia7712 commented on code in PR #15761:
URL: https://github.com/apache/kafka/pull/15761#discussion_r1580536170
##
core/src/test/java/kafka/test/ClusterTestExtensionsTest.java:
##
@@ -48,14 +51,18 @@ public class ClusterTestExtensionsTest {
// Static methods can generate
brandboat commented on code in PR #15761:
URL: https://github.com/apache/kafka/pull/15761#discussion_r1580549838
##
core/src/test/java/kafka/test/ClusterTestExtensionsTest.java:
##
@@ -48,14 +51,18 @@ public class ClusterTestExtensionsTest {
// Static methods can
abhijeetk88 commented on code in PR #15625:
URL: https://github.com/apache/kafka/pull/15625#discussion_r1580557688
##
core/src/main/java/kafka/log/remote/quota/RLMQuotaManager.java:
##
@@ -0,0 +1,119 @@
+/*
+ * 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_r1580538394
##
core/src/test/java/kafka/test/ClusterConfig.java:
##
@@ -139,28 +151,38 @@ public Map nameTags() {
return tags;
}
-public ClusterConfig
Kuan Po Tseng created KAFKA-16627:
-
Summary: Remove ClusterConfig parameter in BeforeEach and AfterEach
Key: KAFKA-16627
URL: https://issues.apache.org/jira/browse/KAFKA-16627
Project: Kafka
chia7712 merged PR #15811:
URL: https://github.com/apache/kafka/pull/15811
--
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-16622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17841072#comment-17841072
]
Greg Harris commented on KAFKA-16622:
-
[~ecomar] Do you know if the MirrorCheckpointTask
chia7712 commented on PR #15811:
URL: https://github.com/apache/kafka/pull/15811#issuecomment-2078756363
The failed tests are unrelated. will merge 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 above to
brandboat commented on code in PR #15761:
URL: https://github.com/apache/kafka/pull/15761#discussion_r1580544105
##
core/src/test/java/kafka/test/ClusterConfig.java:
##
@@ -139,28 +151,38 @@ public Map nameTags() {
return tags;
}
-public ClusterConfig
chia7712 commented on code in PR #15761:
URL: https://github.com/apache/kafka/pull/15761#discussion_r1580542830
##
core/src/test/java/kafka/test/ClusterConfig.java:
##
@@ -139,28 +151,38 @@ public Map nameTags() {
return tags;
}
-public ClusterConfig
abhijeetk88 commented on code in PR #15625:
URL: https://github.com/apache/kafka/pull/15625#discussion_r1580549399
##
core/src/main/java/kafka/log/remote/quota/RLMQuotaManagerConfig.java:
##
@@ -0,0 +1,50 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or
[
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_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_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
+
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
[
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
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_
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_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_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
+
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.
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
+
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
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:
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
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
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-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
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
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() {
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
[
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:
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
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
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(
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
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
+//
[
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
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();
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_
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
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
[
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
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() {
[
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?
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
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
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 #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 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 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 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 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
[
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
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(
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
+//
[
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
>
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
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 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 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
1 - 100 of 137 matches
Mail list logo
