lihaosky commented on code in PR #14097:
URL: https://github.com/apache/kafka/pull/14097#discussion_r1277119690
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/RackAwareTaskAssignor.java:
##
@@ -63,11 +62,11 @@ public RackAwareTaskAssignor(final
satishd merged PR #14049:
URL: https://github.com/apache/kafka/pull/14049
--
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:
satishd commented on PR #14049:
URL: https://github.com/apache/kafka/pull/14049#issuecomment-1655051965
A few unrelated test failures in Jenkins jobs, merging it to trunk.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
[
https://issues.apache.org/jira/browse/KAFKA-15231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17748406#comment-17748406
]
Satish Duggana edited comment on KAFKA-15231 at 7/28/23 4:48 AM:
-
There
[
https://issues.apache.org/jira/browse/KAFKA-15231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17748406#comment-17748406
]
Satish Duggana commented on KAFKA-15231:
There can be scenarios where you want to control more
[
https://issues.apache.org/jira/browse/KAFKA-15265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Satish Duggana updated KAFKA-15265:
---
Description: Related KIP:
Satish Duggana created KAFKA-15265:
--
Summary: Remote copy/fetch quotas for tiered storage.
Key: KAFKA-15265
URL: https://issues.apache.org/jira/browse/KAFKA-15265
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-15214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17748402#comment-17748402
]
Satish Duggana commented on KAFKA-15214:
[~yaolixin] Is the client trying to fetch the remote
github-actions[bot] commented on PR #13568:
URL: https://github.com/apache/kafka/pull/13568#issuecomment-1654936322
This PR is being marked as stale since it has not had any activity in 90
days. If you would like to keep this PR alive, please ask a committer for
review. If the PR has
mjsax commented on code in PR #14097:
URL: https://github.com/apache/kafka/pull/14097#discussion_r1277018411
##
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/ClientTagAwareStandbyTaskAssignorTest.java:
##
@@ -313,20 +315,145 @@ public void
mjsax commented on code in PR #14097:
URL: https://github.com/apache/kafka/pull/14097#discussion_r1277018411
##
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/ClientTagAwareStandbyTaskAssignorTest.java:
##
@@ -313,20 +315,145 @@ public void
mjsax commented on code in PR #14097:
URL: https://github.com/apache/kafka/pull/14097#discussion_r1277018411
##
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/ClientTagAwareStandbyTaskAssignorTest.java:
##
@@ -313,20 +315,145 @@ public void
mjsax commented on code in PR #14097:
URL: https://github.com/apache/kafka/pull/14097#discussion_r1277015051
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/RackAwareTaskAssignor.java:
##
@@ -63,11 +62,11 @@ public RackAwareTaskAssignor(final
mjsax commented on code in PR #14097:
URL: https://github.com/apache/kafka/pull/14097#discussion_r1277015051
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/RackAwareTaskAssignor.java:
##
@@ -63,11 +62,11 @@ public RackAwareTaskAssignor(final
mjsax commented on code in PR #14097:
URL: https://github.com/apache/kafka/pull/14097#discussion_r1277015051
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/RackAwareTaskAssignor.java:
##
@@ -63,11 +62,11 @@ public RackAwareTaskAssignor(final
mjsax commented on code in PR #14097:
URL: https://github.com/apache/kafka/pull/14097#discussion_r1277014726
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/RackAwareTaskAssignor.java:
##
@@ -63,11 +62,11 @@ public RackAwareTaskAssignor(final
[
https://issues.apache.org/jira/browse/KAFKA-15264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jianbin.chen updated KAFKA-15264:
-
Attachment: image-2023-07-28-09-52-38-941.png
Description:
I was preparing to upgrade from
[
https://issues.apache.org/jira/browse/KAFKA-15259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17748367#comment-17748367
]
Matthias J. Sax commented on KAFKA-15259:
-
Thanks for getting back – I was just asking a general
[
https://issues.apache.org/jira/browse/KAFKA-15264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jianbin.chen updated KAFKA-15264:
-
Attachment: image-2023-07-28-09-51-01-662.png
Description:
I was preparing to upgrade from
jeffkbkim commented on PR #14117:
URL: https://github.com/apache/kafka/pull/14117#issuecomment-1654851021
can you point me to where the log context includes the topic partition info?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
jianbin.chen created KAFKA-15264:
Summary: Compared with 1.1.0zk, the peak throughput of 3.5.1kraft
is very jitter
Key: KAFKA-15264
URL: https://issues.apache.org/jira/browse/KAFKA-15264
Project:
philipnee commented on PR #14086:
URL: https://github.com/apache/kafka/pull/14086#issuecomment-1654826392
Hey @junrao Thanks a lot for reviewing this. I fixed the broken build and
here are the failing tests. I believe they are unrelated:
```
Build / JDK 17 and Scala 2.13 /
jeffkbkim commented on code in PR #14056:
URL: https://github.com/apache/kafka/pull/14056#discussion_r1276971308
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTest.java:
##
@@ -8540,5 +8568,1182 @@ private static class RebalanceResult
jeffkbkim commented on code in PR #14056:
URL: https://github.com/apache/kafka/pull/14056#discussion_r1276959521
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTest.java:
##
@@ -8540,5 +8568,1182 @@ private static class RebalanceResult
cmccabe merged PR #13643:
URL: https://github.com/apache/kafka/pull/13643
--
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:
jeffkbkim commented on code in PR #14056:
URL: https://github.com/apache/kafka/pull/14056#discussion_r1276944101
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTest.java:
##
@@ -8540,5 +8568,1182 @@ private static class RebalanceResult
jeffkbkim commented on code in PR #14056:
URL: https://github.com/apache/kafka/pull/14056#discussion_r1276943880
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTest.java:
##
@@ -8540,5 +8568,1182 @@ private static class RebalanceResult
jeffkbkim commented on code in PR #14056:
URL: https://github.com/apache/kafka/pull/14056#discussion_r1276942521
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTest.java:
##
@@ -8540,5 +8568,1182 @@ private static class RebalanceResult
jeffkbkim commented on code in PR #14056:
URL: https://github.com/apache/kafka/pull/14056#discussion_r1276939557
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTest.java:
##
@@ -8540,5 +8568,1182 @@ private static class RebalanceResult
jeffkbkim commented on code in PR #14056:
URL: https://github.com/apache/kafka/pull/14056#discussion_r1276936889
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTest.java:
##
@@ -8540,5 +8568,1182 @@ private static class RebalanceResult
jeffkbkim commented on code in PR #14056:
URL: https://github.com/apache/kafka/pull/14056#discussion_r1276923811
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTest.java:
##
@@ -8540,5 +8568,1182 @@ private static class RebalanceResult
jeffkbkim commented on code in PR #14056:
URL: https://github.com/apache/kafka/pull/14056#discussion_r1276922896
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTest.java:
##
@@ -8540,5 +8568,1182 @@ private static class RebalanceResult
jeffkbkim commented on code in PR #14056:
URL: https://github.com/apache/kafka/pull/14056#discussion_r1276921862
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTest.java:
##
@@ -8540,5 +8568,1182 @@ private static class RebalanceResult
jeffkbkim commented on code in PR #14056:
URL: https://github.com/apache/kafka/pull/14056#discussion_r1276919519
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTest.java:
##
@@ -8540,5 +8568,1182 @@ private static class RebalanceResult
jeffkbkim commented on code in PR #14056:
URL: https://github.com/apache/kafka/pull/14056#discussion_r1276919382
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTest.java:
##
@@ -8540,5 +8568,1182 @@ private static class RebalanceResult
jeffkbkim commented on code in PR #14056:
URL: https://github.com/apache/kafka/pull/14056#discussion_r1276874868
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorService.java:
##
@@ -368,9 +369,29 @@ public CompletableFuture heartbeat(
philipnee opened a new pull request, #14118:
URL: https://github.com/apache/kafka/pull/14118
Continuation of https://github.com/apache/kafka/pull/13490. I closed the
original one due to rebase difficulties.
**Summary
Implemented wakeup() mechanism using a WakeupTrigger class to
philipnee closed pull request #13490: KAFKA-14875: Implement wakeup
URL: https://github.com/apache/kafka/pull/13490
--
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
rreddy-22 commented on code in PR #14099:
URL: https://github.com/apache/kafka/pull/14099#discussion_r1276830477
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/RecordHelpersTest.java:
##
@@ -764,4 +813,39 @@ public void
rreddy-22 commented on code in PR #14099:
URL: https://github.com/apache/kafka/pull/14099#discussion_r1276830285
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTest.java:
##
@@ -5567,7 +5600,7 @@ public void
rondagostino commented on code in PR #14084:
URL: https://github.com/apache/kafka/pull/14084#discussion_r1276771939
##
tests/kafkatest/version.py:
##
@@ -252,3 +252,7 @@ def get_version(node=None):
V_3_5_0 = KafkaVersion("3.5.0")
V_3_5_1 = KafkaVersion("3.5.1")
LATEST_3_5 =
[
https://issues.apache.org/jira/browse/KAFKA-14976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman reassigned KAFKA-14976:
--
Assignee: Almog Gavra
> Left/outer stream-stream joins create KV
[
https://issues.apache.org/jira/browse/KAFKA-14976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman updated KAFKA-14976:
---
Labels: kip (was: needs-kip)
> Left/outer stream-stream joins create KV
[
https://issues.apache.org/jira/browse/KAFKA-14976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17748314#comment-17748314
]
A. Sophie Blee-Goldman commented on KAFKA-14976:
Will be addressed by
ableegoldman commented on PR #13920:
URL: https://github.com/apache/kafka/pull/13920#issuecomment-1654436865
@flashmouse you can decrease the consumer count. For one thing, this covers
the edge case where the consumers do not all have the same topic subscription,
which seems to be quite
dajac commented on code in PR #14099:
URL: https://github.com/apache/kafka/pull/14099#discussion_r1276742165
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTest.java:
##
@@ -5567,7 +5600,7 @@ public void
dajac commented on code in PR #14099:
URL: https://github.com/apache/kafka/pull/14099#discussion_r1276739854
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/RecordHelpersTest.java:
##
@@ -764,4 +813,39 @@ public void testNewOffsetCommitTombstoneRecord() {
dajac opened a new pull request, #14117:
URL: https://github.com/apache/kafka/pull/14117
This patch does a few code cleanups in the group-coordinator module.
- It renames `Coordinator` to `CoordinatorShard`;
- It renames `ReplicatedGroupCoordinator` to `GroupCoordinatorShard`. I was
kamalcph opened a new pull request, #14116:
URL: https://github.com/apache/kafka/pull/14116
*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
rreddy-22 commented on code in PR #14099:
URL: https://github.com/apache/kafka/pull/14099#discussion_r1276710063
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/RecordHelpersTest.java:
##
@@ -764,4 +813,39 @@ public void
cmccabe commented on PR #13643:
URL: https://github.com/apache/kafka/pull/13643#issuecomment-1654254344
> I couldn't find a test for the new KafkaRaftClient::scheduleAtomicAppend.
I added `KafkaRaftClientTest.testAppendWithRequiredBaseOffset`.
--
This is an automated message from
rreddy-22 commented on code in PR #14099:
URL: https://github.com/apache/kafka/pull/14099#discussion_r1276706144
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTest.java:
##
@@ -5692,12 +5725,60 @@ private void
cmccabe commented on PR #13643:
URL: https://github.com/apache/kafka/pull/13643#issuecomment-1654251894
> @cmccabe, I don't follow this comment. When the client calls
KafkaRaftClient::schedule{Atomic}Append the KafkaRaftClient compare the
provided offset with the nextOffset stored in the
rreddy-22 commented on code in PR #14099:
URL: https://github.com/apache/kafka/pull/14099#discussion_r1276701201
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTest.java:
##
@@ -5567,7 +5600,7 @@ public void
rreddy-22 commented on code in PR #14099:
URL: https://github.com/apache/kafka/pull/14099#discussion_r1276693242
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/consumer/TopicMetadata.java:
##
@@ -40,23 +45,31 @@ public class TopicMetadata {
*/
cmccabe commented on code in PR #13643:
URL: https://github.com/apache/kafka/pull/13643#discussion_r1276690892
##
raft/src/main/java/org/apache/kafka/raft/RaftClient.java:
##
@@ -171,16 +172,21 @@ default void beginShutdown() {}
* to resign its leadership. The state
dajac commented on code in PR #14099:
URL: https://github.com/apache/kafka/pull/14099#discussion_r1276677238
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/consumer/ConsumerGroupTest.java:
##
@@ -440,12 +442,13 @@ public void
dajac commented on code in PR #14099:
URL: https://github.com/apache/kafka/pull/14099#discussion_r1276671418
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/consumer/TargetAssignmentBuilderTest.java:
##
@@ -84,14 +85,15 @@ public void addGroupMember(
dajac commented on code in PR #14099:
URL: https://github.com/apache/kafka/pull/14099#discussion_r1276670928
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/consumer/SubscribedTopicMetadataTest.java:
##
@@ -0,0 +1,74 @@
+/*
+ * Licensed to the Apache
dajac commented on code in PR #14099:
URL: https://github.com/apache/kafka/pull/14099#discussion_r1276670286
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/assignor/RangeAssignorTest.java:
##
@@ -571,4 +716,14 @@ private void assertAssignment(Map>>
dajac commented on code in PR #14099:
URL: https://github.com/apache/kafka/pull/14099#discussion_r1276669652
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/RecordHelpersTest.java:
##
@@ -764,4 +813,39 @@ public void testNewOffsetCommitTombstoneRecord() {
dajac commented on code in PR #14099:
URL: https://github.com/apache/kafka/pull/14099#discussion_r1276668936
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/RecordHelpersTest.java:
##
@@ -612,15 +616,14 @@ public void
dajac commented on code in PR #14099:
URL: https://github.com/apache/kafka/pull/14099#discussion_r127851
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTest.java:
##
@@ -5692,12 +5725,60 @@ private void
dajac commented on code in PR #14099:
URL: https://github.com/apache/kafka/pull/14099#discussion_r1276663083
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTest.java:
##
@@ -5692,12 +5725,60 @@ private void
dajac commented on code in PR #14099:
URL: https://github.com/apache/kafka/pull/14099#discussion_r1276659754
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTest.java:
##
@@ -5692,12 +5725,60 @@ private void
dajac commented on code in PR #14099:
URL: https://github.com/apache/kafka/pull/14099#discussion_r1276659754
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTest.java:
##
@@ -5692,12 +5725,60 @@ private void
dajac commented on code in PR #14099:
URL: https://github.com/apache/kafka/pull/14099#discussion_r1276653838
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTest.java:
##
@@ -5567,7 +5600,7 @@ public void
[
https://issues.apache.org/jira/browse/KAFKA-14748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17748285#comment-17748285
]
Guozhang Wang commented on KAFKA-14748:
---
[~aki] Thanks for picking this series! I think we can
[
https://issues.apache.org/jira/browse/KAFKA-12317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17748284#comment-17748284
]
Guozhang Wang commented on KAFKA-12317:
---
[~mjsax] Though it may not introduce any new configs or
[
https://issues.apache.org/jira/browse/KAFKA-15240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17748281#comment-17748281
]
Guozhang Wang commented on KAFKA-15240:
---
[~lushilin] Thanks for reporting this. I think [~cmccabe]
ahuang98 commented on code in PR #14084:
URL: https://github.com/apache/kafka/pull/14084#discussion_r1276628397
##
tests/kafkatest/version.py:
##
@@ -252,3 +252,7 @@ def get_version(node=None):
V_3_5_0 = KafkaVersion("3.5.0")
V_3_5_1 = KafkaVersion("3.5.1")
LATEST_3_5 =
mumrah commented on code in PR #14115:
URL: https://github.com/apache/kafka/pull/14115#discussion_r1276619004
##
metadata/src/main/java/org/apache/kafka/metadata/migration/KRaftMigrationDriver.java:
##
@@ -297,6 +297,16 @@ private boolean isValidStateChange(MigrationDriverState
cmccabe commented on code in PR #14115:
URL: https://github.com/apache/kafka/pull/14115#discussion_r1276615552
##
metadata/src/main/java/org/apache/kafka/metadata/migration/KRaftMigrationDriver.java:
##
@@ -297,6 +297,16 @@ private boolean
mumrah commented on code in PR #14115:
URL: https://github.com/apache/kafka/pull/14115#discussion_r1276614670
##
metadata/src/main/java/org/apache/kafka/metadata/migration/KRaftMigrationDriver.java:
##
@@ -599,6 +604,9 @@ public void run() throws Exception {
class
rreddy-22 commented on code in PR #14099:
URL: https://github.com/apache/kafka/pull/14099#discussion_r1276612481
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/RecordHelpersTest.java:
##
@@ -612,15 +616,14 @@ public void
rondagostino commented on code in PR #14084:
URL: https://github.com/apache/kafka/pull/14084#discussion_r1276607523
##
tests/kafkatest/version.py:
##
@@ -252,3 +252,7 @@ def get_version(node=None):
V_3_5_0 = KafkaVersion("3.5.0")
V_3_5_1 = KafkaVersion("3.5.1")
LATEST_3_5 =
mumrah opened a new pull request, #14115:
URL: https://github.com/apache/kafka/pull/14115
To avoid processing events once we have transitioned to a new state, add a
check at the beginning of the events created by PollEvent in
KRaftMigrationDriver.
--
This is an automated message from
kamalcph commented on PR #14114:
URL: https://github.com/apache/kafka/pull/14114#issuecomment-1654008152
@satishd @divijvaidya @showuon
PTAL when you get chance!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
David Arthur created KAFKA-15263:
Summary: KRaftMigrationDriver can run the migration twice
Key: KAFKA-15263
URL: https://issues.apache.org/jira/browse/KAFKA-15263
Project: Kafka
Issue Type:
rreddy-22 commented on code in PR #14099:
URL: https://github.com/apache/kafka/pull/14099#discussion_r1276573086
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/consumer/SubscribedTopicMetadata.java:
##
@@ -0,0 +1,88 @@
+/*
+ * Licensed to the Apache
kamalcph opened a new pull request, #14114:
URL: https://github.com/apache/kafka/pull/14114
**Topic -> Broker Synonym**
- local.retention.bytes -> log.local.retention.bytes
- local.retention.ms -> log.local.retention.ms
We cannot add synonym for `remote.storage.enable`
jolshan merged PR #14088:
URL: https://github.com/apache/kafka/pull/14088
--
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:
clolov commented on code in PR #14049:
URL: https://github.com/apache/kafka/pull/14049#discussion_r1276543815
##
storage/api/src/test/java/org/apache/kafka/server/log/remote/storage/NoOpRemoteLogMetadataManager.java:
##
@@ -74,6 +74,11 @@ public void
philipnee commented on PR #13920:
URL: https://github.com/apache/kafka/pull/13920#issuecomment-1653959801
Hmm - you can try. But I've had similar, if not the same, failures and I
haven't had a chance to examine the cause.
--
This is an automated message from the Apache Git Service.
To
abhijeetk88 opened a new pull request, #14113:
URL: https://github.com/apache/kafka/pull/14113
*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-15262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ravindranath Kakarla updated KAFKA-15262:
-
Description:
As per the MM2
rreddy-22 commented on code in PR #14099:
URL: https://github.com/apache/kafka/pull/14099#discussion_r1276487843
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/consumer/TargetAssignmentBuilderTest.java:
##
@@ -624,8 +745,27 @@ public void
rreddy-22 commented on code in PR #14099:
URL: https://github.com/apache/kafka/pull/14099#discussion_r1275444245
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/consumer/TargetAssignmentBuilderTest.java:
##
@@ -624,8 +745,27 @@ public void
[
https://issues.apache.org/jira/browse/KAFKA-15262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ravindranath Kakarla updated KAFKA-15262:
-
Description:
As per the MM2
[
https://issues.apache.org/jira/browse/KAFKA-15262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ravindranath Kakarla updated KAFKA-15262:
-
Description:
As per the MM2
[
https://issues.apache.org/jira/browse/KAFKA-15262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ravindranath Kakarla updated KAFKA-15262:
-
Description:
As per the MM2 [KIP-382 |
[
https://issues.apache.org/jira/browse/KAFKA-15262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ravindranath Kakarla updated KAFKA-15262:
-
Description:
As per the MM2
Ravindranath Kakarla created KAFKA-15262:
Summary: MirrorHeartbeatConnector is not working as documented
Key: KAFKA-15262
URL: https://issues.apache.org/jira/browse/KAFKA-15262
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-14509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17748216#comment-17748216
]
Max Riedel edited comment on KAFKA-14509 at 7/27/23 3:40 PM:
-
Hey [~dajac],
[
https://issues.apache.org/jira/browse/KAFKA-14509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17748216#comment-17748216
]
Max Riedel edited comment on KAFKA-14509 at 7/27/23 3:39 PM:
-
Hey [~dajac],
[
https://issues.apache.org/jira/browse/KAFKA-14509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17748216#comment-17748216
]
Max Riedel commented on KAFKA-14509:
Hey [~dajac],
I started implementing the request/response
mimaison commented on PR #13671:
URL: https://github.com/apache/kafka/pull/13671#issuecomment-1653859939
Thanks @hertzsprung for the PR!
No code in Kafka relies on the content of CreateTopicsResult, and I just
realized MockAdminClient is not part of the public API so this is effectively
abhijeetk88 opened a new pull request, #14112:
URL: https://github.com/apache/kafka/pull/14112
*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
ex172000 commented on PR #14110:
URL: https://github.com/apache/kafka/pull/14110#issuecomment-1653814175
The test failed, but not related. All failed tests are integration test and
this is a unit test only change.
--
This is an automated message from the Apache Git Service.
To respond to
jsancio commented on code in PR #13643:
URL: https://github.com/apache/kafka/pull/13643#discussion_r1276417011
##
raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java:
##
@@ -2394,6 +2394,11 @@ public Optional latestSnapshotId() {
return
1 - 100 of 154 matches
Mail list logo
