satishd merged PR #14045:
URL: https://github.com/apache/kafka/pull/14045
--
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 #14045:
URL: https://github.com/apache/kafka/pull/14045#issuecomment-1646452657
A few failed tests are observed on the Jenkins build jobs but they do not
seem to be related, merging it to trunk.
--
This is an automated message from the Apache Git Service.
To
kirktrue commented on PR #13990:
URL: https://github.com/apache/kafka/pull/13990#issuecomment-1646378435
@junrao The JDK 11, 17, and 20 test runs output this as their last test
execution:
```
Gradle Test Run :streams:integrationTest > Gradle Test Executor 177 >
kirktrue commented on PR #13990:
URL: https://github.com/apache/kafka/pull/13990#issuecomment-1646371022
@junrao In [the JDK 11
run](https://ci-builds.apache.org/blue/organizations/jenkins/Kafka%2Fkafka-pr/detail/PR-13990/23/tests),
`DeleteTopicTest.testDeleteTopicWithCleaner()` fails and
jolshan commented on code in PR #14067:
URL: https://github.com/apache/kafka/pull/14067#discussion_r1271176157
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/OffsetMetadataManager.java:
##
@@ -0,0 +1,448 @@
+/*
+ * Licensed to the Apache Software
jolshan commented on code in PR #14067:
URL: https://github.com/apache/kafka/pull/14067#discussion_r1271176157
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/OffsetMetadataManager.java:
##
@@ -0,0 +1,448 @@
+/*
+ * Licensed to the Apache Software
jolshan commented on code in PR #14067:
URL: https://github.com/apache/kafka/pull/14067#discussion_r1271173194
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java:
##
@@ -408,6 +408,31 @@ public MetadataImage image() {
return
jolshan commented on code in PR #14067:
URL: https://github.com/apache/kafka/pull/14067#discussion_r1271172931
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/OffsetMetadataManager.java:
##
@@ -0,0 +1,448 @@
+/*
+ * Licensed to the Apache Software
jolshan commented on code in PR #14067:
URL: https://github.com/apache/kafka/pull/14067#discussion_r1271172931
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/OffsetMetadataManager.java:
##
@@ -0,0 +1,448 @@
+/*
+ * Licensed to the Apache Software
jolshan commented on code in PR #14067:
URL: https://github.com/apache/kafka/pull/14067#discussion_r1271172399
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/OffsetMetadataManager.java:
##
@@ -0,0 +1,448 @@
+/*
+ * Licensed to the Apache Software
jolshan commented on code in PR #14067:
URL: https://github.com/apache/kafka/pull/14067#discussion_r1271168880
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorService.java:
##
@@ -471,9 +472,48 @@ public CompletableFuture
commitOffsets(
jolshan commented on code in PR #14062:
URL: https://github.com/apache/kafka/pull/14062#discussion_r1271166831
##
metadata/src/main/java/org/apache/kafka/metadata/migration/KRaftMigrationDriver.java:
##
@@ -756,4 +745,109 @@ static KRaftMigrationOperationConsumer
mjsax commented on code in PR #14030:
URL: https://github.com/apache/kafka/pull/14030#discussion_r1271152663
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/RackAwareTaskAssignor.java:
##
@@ -185,4 +191,224 @@ public boolean validateClientRack()
mjsax commented on code in PR #14030:
URL: https://github.com/apache/kafka/pull/14030#discussion_r1271152663
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/RackAwareTaskAssignor.java:
##
@@ -185,4 +191,224 @@ public boolean validateClientRack()
mjsax commented on code in PR #14030:
URL: https://github.com/apache/kafka/pull/14030#discussion_r1271151967
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/RackAwareTaskAssignor.java:
##
@@ -185,4 +191,224 @@ public boolean validateClientRack()
mjsax commented on code in PR #14030:
URL: https://github.com/apache/kafka/pull/14030#discussion_r1270106140
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/RackAwareTaskAssignor.java:
##
@@ -185,4 +191,224 @@ public boolean validateClientRack()
mjsax commented on code in PR #13996:
URL: https://github.com/apache/kafka/pull/13996#discussion_r1271148006
##
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/GraphTest.java:
##
@@ -0,0 +1,414 @@
+/*
+ * Licensed to the Apache Software Foundation
mjsax commented on code in PR #13996:
URL: https://github.com/apache/kafka/pull/13996#discussion_r1271147536
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/Graph.java:
##
@@ -0,0 +1,377 @@
+/*
+ * Licensed to the Apache Software Foundation
mjsax commented on code in PR #13996:
URL: https://github.com/apache/kafka/pull/13996#discussion_r1270057798
##
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/GraphTest.java:
##
@@ -0,0 +1,414 @@
+/*
+ * Licensed to the Apache Software Foundation
splett2 commented on PR #14050:
URL: https://github.com/apache/kafka/pull/14050#issuecomment-1646268752
Failing tests:
```
Build / JDK 8 and Scala 2.12 / testOffsetTranslationBehindReplicationFlow()
–
junrao commented on PR #13990:
URL: https://github.com/apache/kafka/pull/13990#issuecomment-1646244882
@kirktrue : In the latest run, it seems that most test failures are from
java 11. I'd suggest looking at the jenkins's log to see the first test that
failed. Sometimes, a failed test
[
https://issues.apache.org/jira/browse/KAFKA-14950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao resolved KAFKA-14950.
-
Fix Version/s: 3.6.0
Resolution: Fixed
merged the PR to trunk.
> Implement assign() and
junrao merged PR #13797:
URL: https://github.com/apache/kafka/pull/13797
--
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:
lihaosky commented on code in PR #14030:
URL: https://github.com/apache/kafka/pull/14030#discussion_r1271098823
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/RackAwareTaskAssignor.java:
##
@@ -38,29 +43,34 @@
public class
lihaosky commented on code in PR #14030:
URL: https://github.com/apache/kafka/pull/14030#discussion_r1271081266
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/RackAwareTaskAssignor.java:
##
@@ -185,4 +191,224 @@ public boolean
gharris1727 commented on code in PR #14055:
URL: https://github.com/apache/kafka/pull/14055#discussion_r1271051021
##
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/Plugins.java:
##
@@ -63,16 +67,72 @@ public Plugins(Map props) {
//
gharris1727 opened a new pull request, #14068:
URL: https://github.com/apache/kafka/pull/14068
This is a restatement of the contents of KIP-898, geared towards a wider
audience.
This documentation is linked from error messages in #14055.
### Committer Checklist (excluded from
rreddy-22 commented on code in PR #13998:
URL: https://github.com/apache/kafka/pull/13998#discussion_r1271047554
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/consumer/TargetAssignmentBuilder.java:
##
@@ -244,16 +245,18 @@ public TargetAssignmentResult
rreddy-22 commented on code in PR #13998:
URL: https://github.com/apache/kafka/pull/13998#discussion_r1271047554
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/consumer/TargetAssignmentBuilder.java:
##
@@ -244,16 +245,18 @@ public TargetAssignmentResult
rreddy-22 commented on code in PR #13998:
URL: https://github.com/apache/kafka/pull/13998#discussion_r1271043473
##
group-coordinator/src/main/resources/common/message/ConsumerGroupPartitionMetadataValue.json:
##
@@ -29,7 +29,27 @@
{ "name": "TopicName", "versions":
kirktrue commented on PR #13990:
URL: https://github.com/apache/kafka/pull/13990#issuecomment-1646176441
> @kirktrue : It seems there were 4 test failures for jdk 11. But the tests
for jdk 17 and 20 were aborted. Do you know why?
@junrao I don't know why yet, no
I have
rreddy-22 commented on code in PR #13998:
URL: https://github.com/apache/kafka/pull/13998#discussion_r1271036247
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/consumer/TopicMetadata.java:
##
@@ -40,23 +44,31 @@ public class TopicMetadata {
*/
[
https://issues.apache.org/jira/browse/KAFKA-15132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17745705#comment-17745705
]
Mehari Beyene commented on KAFKA-15132:
---
KIP:
philipnee commented on PR #13797:
URL: https://github.com/apache/kafka/pull/13797#issuecomment-1646161376
Hey @junrao - Thanks again. I updated the description to reflect the updated
code more accurately. Here I just quoted the paragraph I made the change to:
```
We will explicitly
lihaosky commented on code in PR #13996:
URL: https://github.com/apache/kafka/pull/13996#discussion_r1271010298
##
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/GraphTest.java:
##
@@ -0,0 +1,414 @@
+/*
+ * Licensed to the Apache Software
junrao commented on PR #13947:
URL: https://github.com/apache/kafka/pull/13947#issuecomment-1646140881
Thanks for the comment @clolov. It seems this PR calls
`RemoteLogManager.stopPartitions()`.
--
This is an automated message from the Apache Git Service.
To respond to the message,
junrao commented on code in PR #13947:
URL: https://github.com/apache/kafka/pull/13947#discussion_r1270993960
##
core/src/main/java/kafka/log/remote/RemoteLogManager.java:
##
@@ -119,6 +119,8 @@ public class RemoteLogManager implements Closeable {
private static final
junrao commented on PR #13797:
URL: https://github.com/apache/kafka/pull/13797#issuecomment-1646102324
@philipnee : Could you update the description of the PR (to be included in
the commit message) before I merge it? The description still has the following
and I am not sure if it's still
lihaosky commented on code in PR #13996:
URL: https://github.com/apache/kafka/pull/13996#discussion_r1270971692
##
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/GraphTest.java:
##
@@ -0,0 +1,414 @@
+/*
+ * Licensed to the Apache Software
dajac commented on code in PR #13998:
URL: https://github.com/apache/kafka/pull/13998#discussion_r1270971855
##
group-coordinator/src/main/resources/common/message/ConsumerGroupPartitionMetadataValue.json:
##
@@ -29,7 +29,27 @@
{ "name": "TopicName", "versions": "0+",
mimaison merged PR #14066:
URL: https://github.com/apache/kafka/pull/14066
--
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:
dajac commented on code in PR #13998:
URL: https://github.com/apache/kafka/pull/13998#discussion_r1270967491
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/AssignmentTopicDescriber.java:
##
@@ -0,0 +1,59 @@
+/*
+ * Licensed to the Apache Software
gharris1727 commented on PR #14055:
URL: https://github.com/apache/kafka/pull/14055#issuecomment-1646086669
> The question of plugins that are installed directly onto the classpath
might be a bit tricky... let me know if I've missed something. My current
understanding is that these plugins
dajac commented on code in PR #13998:
URL: https://github.com/apache/kafka/pull/13998#discussion_r1270966763
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/AssignmentTopicMetadata.java:
##
@@ -16,44 +16,83 @@
*/
package
dajac commented on code in PR #13998:
URL: https://github.com/apache/kafka/pull/13998#discussion_r1270965310
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/RangeAssignor.java:
##
@@ -87,7 +87,7 @@ private Map> membersPerTopic(final
[
https://issues.apache.org/jira/browse/KAFKA-15116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17745690#comment-17745690
]
Matthias J. Sax edited comment on KAFKA-15116 at 7/21/23 6:18 PM:
--
[
https://issues.apache.org/jira/browse/KAFKA-15116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17745690#comment-17745690
]
Matthias J. Sax commented on KAFKA-15116:
-
{quote}The internal store is shared across stream
dajac commented on code in PR #14067:
URL: https://github.com/apache/kafka/pull/14067#discussion_r1270960303
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/OffsetMetadataManager.java:
##
@@ -0,0 +1,448 @@
+/*
+ * Licensed to the Apache Software Foundation
dajac commented on code in PR #14067:
URL: https://github.com/apache/kafka/pull/14067#discussion_r1270959863
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/OffsetMetadataManager.java:
##
@@ -0,0 +1,448 @@
+/*
+ * Licensed to the Apache Software Foundation
dajac commented on code in PR #14067:
URL: https://github.com/apache/kafka/pull/14067#discussion_r1270959230
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/OffsetMetadataManager.java:
##
@@ -0,0 +1,448 @@
+/*
+ * Licensed to the Apache Software Foundation
dajac opened a new pull request, #14067:
URL: https://github.com/apache/kafka/pull/14067
This patch introduces the `OffsetMetadataManager` and implements the
`OffsetCommit` API for both the old rebalance protocol and the new rebalance
protocol.
### Committer Checklist (excluded from
dajac merged PR #14047:
URL: https://github.com/apache/kafka/pull/14047
--
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:
dajac commented on PR #14047:
URL: https://github.com/apache/kafka/pull/14047#issuecomment-1646069623
Failed tests are unrelated. Merging to trunk.
--
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 merged PR #14046:
URL: https://github.com/apache/kafka/pull/14046
--
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:
dajac commented on PR #14046:
URL: https://github.com/apache/kafka/pull/14046#issuecomment-1646067746
Failed tests are unrelated. Merging to trunk.
--
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
jeffkbkim commented on code in PR #14017:
URL: https://github.com/apache/kafka/pull/14017#discussion_r1270946493
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTest.java:
##
@@ -5524,5 +5670,2897 @@ private static Record
Greg Harris created KAFKA-15233:
---
Summary: Add public documentation for plugin.discovery migration
steps
Key: KAFKA-15233
URL: https://issues.apache.org/jira/browse/KAFKA-15233
Project: Kafka
jeffkbkim commented on code in PR #14017:
URL: https://github.com/apache/kafka/pull/14017#discussion_r1270943845
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTest.java:
##
@@ -5524,5 +5670,2897 @@ private static Record
jeffkbkim commented on code in PR #14017:
URL: https://github.com/apache/kafka/pull/14017#discussion_r1270940010
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTest.java:
##
@@ -5524,5 +5670,2897 @@ private static Record
jeffkbkim commented on code in PR #14017:
URL: https://github.com/apache/kafka/pull/14017#discussion_r1270939083
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTest.java:
##
@@ -5524,5 +5670,2897 @@ private static Record
gharris1727 commented on code in PR #14055:
URL: https://github.com/apache/kafka/pull/14055#discussion_r1270918323
##
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/Plugins.java:
##
@@ -63,16 +67,72 @@ public Plugins(Map props) {
//
jeffkbkim commented on code in PR #14017:
URL: https://github.com/apache/kafka/pull/14017#discussion_r1270937110
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java:
##
@@ -2643,9 +2652,175 @@ private CoordinatorResult
jeffkbkim commented on code in PR #14017:
URL: https://github.com/apache/kafka/pull/14017#discussion_r1270934792
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTest.java:
##
@@ -5524,5 +5670,2897 @@ private static Record
jeffkbkim commented on code in PR #14017:
URL: https://github.com/apache/kafka/pull/14017#discussion_r1270929646
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTest.java:
##
@@ -5524,5 +5670,2897 @@ private static Record
jeffkbkim commented on code in PR #14017:
URL: https://github.com/apache/kafka/pull/14017#discussion_r1270926383
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTest.java:
##
@@ -5524,5 +5670,2897 @@ private static Record
ruslankrivoshein commented on code in PR #13562:
URL: https://github.com/apache/kafka/pull/13562#discussion_r1270907553
##
tools/src/main/java/org/apache/kafka/tools/ToolsUtils.java:
##
@@ -0,0 +1,44 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
jeffkbkim commented on code in PR #14017:
URL: https://github.com/apache/kafka/pull/14017#discussion_r1270901334
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTest.java:
##
@@ -5524,5 +5670,2897 @@ private static Record
nizhikov commented on PR #13247:
URL: https://github.com/apache/kafka/pull/13247#issuecomment-1645993319
@mimaison Thanks for the review. I will address your comments in the nearest
time.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
nizhikov commented on PR #13278:
URL: https://github.com/apache/kafka/pull/13278#issuecomment-1645987767
@fvaleri @mimaison Thank you for the review and merge!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
fvaleri commented on code in PR #13417:
URL: https://github.com/apache/kafka/pull/13417#discussion_r1270828901
##
checkstyle/import-control.xml:
##
@@ -302,6 +302,11 @@
+
+
+
+
+
Review Comment:
This entry is duplicated, and we don't
fvaleri commented on code in PR #13562:
URL: https://github.com/apache/kafka/pull/13562#discussion_r1270884317
##
tools/src/main/java/org/apache/kafka/tools/ToolsUtils.java:
##
@@ -0,0 +1,44 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ *
[
https://issues.apache.org/jira/browse/KAFKA-14851?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Federico Valeri updated KAFKA-14851:
Summary: Move StreamResetterTest to tools (was: Move StreamResetterTest to
tools module)
philipnee commented on code in PR #13920:
URL: https://github.com/apache/kafka/pull/13920#discussion_r1270851855
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignorTest.java:
##
@@ -724,6 +725,90 @@ public void
ruslankrivoshein commented on code in PR #13562:
URL: https://github.com/apache/kafka/pull/13562#discussion_r1270873057
##
tools/src/main/java/org/apache/kafka/tools/ToolsUtils.java:
##
@@ -0,0 +1,44 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
ruslankrivoshein commented on code in PR #13562:
URL: https://github.com/apache/kafka/pull/13562#discussion_r1270873057
##
tools/src/main/java/org/apache/kafka/tools/ToolsUtils.java:
##
@@ -0,0 +1,44 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
[
https://issues.apache.org/jira/browse/KAFKA-13431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton resolved KAFKA-13431.
---
Fix Version/s: 3.6.0
Resolution: Done
> Sink Connectors: Support topic-mutating SMTs
C0urante commented on code in PR #14055:
URL: https://github.com/apache/kafka/pull/14055#discussion_r1270745253
##
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerConfig.java:
##
@@ -122,6 +124,18 @@ public class WorkerConfig extends AbstractConfig {
mimaison merged PR #13278:
URL: https://github.com/apache/kafka/pull/13278
--
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-15232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Federico Valeri reassigned KAFKA-15232:
---
Assignee: Federico Valeri
> Move ToolsUtils to tools
>
>
Federico Valeri created KAFKA-15232:
---
Summary: Move ToolsUtils to tools
Key: KAFKA-15232
URL: https://issues.apache.org/jira/browse/KAFKA-15232
Project: Kafka
Issue Type: Sub-task
Owen-CH-Leung commented on PR #14057:
URL: https://github.com/apache/kafka/pull/14057#issuecomment-1645730474
I've already merged trunk and this time the `JDK 11 + Scala 2.13` failed:
```
1: Task failed with an exception.
---
* What went wrong:
Execution failed
[
https://issues.apache.org/jira/browse/KAFKA-14583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Federico Valeri updated KAFKA-14583:
Fix Version/s: 3.6.0
> Move ReplicaVerificationTool to tools
>
[
https://issues.apache.org/jira/browse/KAFKA-15217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17745507#comment-17745507
]
Said BOUDJELDA edited comment on KAFKA-15217 at 7/21/23 2:28 PM:
-
fvaleri commented on code in PR #13562:
URL: https://github.com/apache/kafka/pull/13562#discussion_r1270733830
##
tools/src/main/java/org/apache/kafka/tools/ToolsUtils.java:
##
@@ -0,0 +1,44 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ *
[
https://issues.apache.org/jira/browse/KAFKA-15231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17745620#comment-17745620
]
Jorge Esteban Quilcate Otoya commented on KAFKA-15231:
--
Thanks [~divijvaidya]. Of
songnon commented on PR #13451:
URL: https://github.com/apache/kafka/pull/13451#issuecomment-1645629406
@junrao I have updated the code. Would you like to have a look? Thanks.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
[
https://issues.apache.org/jira/browse/KAFKA-15231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17745602#comment-17745602
]
Divij Vaidya commented on KAFKA-15231:
--
Hey [~jeqo]
If the RSM is unavailable (for maintenance as
[
https://issues.apache.org/jira/browse/KAFKA-15231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17745600#comment-17745600
]
Jorge Esteban Quilcate Otoya commented on KAFKA-15231:
--
cc [~satishd] [~showuon]
Jorge Esteban Quilcate Otoya created KAFKA-15231:
Summary: Add ability to pause/resume Remote Log Manager tasks
Key: KAFKA-15231
URL: https://issues.apache.org/jira/browse/KAFKA-15231
ruslankrivoshein commented on PR #13562:
URL: https://github.com/apache/kafka/pull/13562#issuecomment-1645561485
```
$ ./gradlew :tools:checkstyleMain
... omitted husk
BUILD SUCCESSFUL
$ ./gradlew clean systemTestLibs
... omitted husk
BUILD SUCCESSFUL
tests run:
fvaleri commented on code in PR #14059:
URL: https://github.com/apache/kafka/pull/14059#discussion_r1270643655
##
tools/src/main/java/org/apache/kafka/tools/ReplicaVerificationTool.java:
##
@@ -0,0 +1,740 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or
fvaleri commented on PR #14059:
URL: https://github.com/apache/kafka/pull/14059#issuecomment-1645541067
@mimaison removed all extra changes.
```sh
SESSION REPORT (ALL TESTS)
ducktape version: 0.11.3
session_id: 2023-07-21--001
run time: 42.089 seconds
fvaleri commented on code in PR #14059:
URL: https://github.com/apache/kafka/pull/14059#discussion_r1270643655
##
tools/src/main/java/org/apache/kafka/tools/ReplicaVerificationTool.java:
##
@@ -0,0 +1,740 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or
fvaleri commented on PR #13562:
URL: https://github.com/apache/kafka/pull/13562#issuecomment-1645507764
Hey @ruslankrivoshein, about the deprecation warning message, it looks like
it is considered a public interface change, so a committer may ask to remove it
or create a KIP, so please
David Arthur created KAFKA-15230:
Summary: ApiVersions data between controllers is not reliable
Key: KAFKA-15230
URL: https://issues.apache.org/jira/browse/KAFKA-15230
Project: Kafka
Issue
mimaison commented on code in PR #14059:
URL: https://github.com/apache/kafka/pull/14059#discussion_r1270606054
##
tools/src/main/java/org/apache/kafka/tools/ReplicaVerificationTool.java:
##
@@ -0,0 +1,740 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or
fvaleri commented on code in PR #14059:
URL: https://github.com/apache/kafka/pull/14059#discussion_r1270544624
##
tools/src/main/java/org/apache/kafka/tools/ReplicaVerificationTool.java:
##
@@ -0,0 +1,740 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or
divijvaidya commented on PR #14057:
URL: https://github.com/apache/kafka/pull/14057#issuecomment-1645447012
Actually, you need to rebase with trunk.
https://github.com/apache/kafka/commit/4ea9394e7ebf71e2dcf96e9b96191dac253f4930
is the commit that fixes the build.
--
This is an
Owen-CH-Leung commented on PR #14057:
URL: https://github.com/apache/kafka/pull/14057#issuecomment-1645437694
Seems like the error from the CI job is not related to what I have changed.
Here are the 3 errors that are reported from the failing CI job:
```
[Error]
fvaleri commented on code in PR #14059:
URL: https://github.com/apache/kafka/pull/14059#discussion_r1270547364
##
tools/src/main/java/org/apache/kafka/tools/ReplicaVerificationTool.java:
##
@@ -0,0 +1,740 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or
1 - 100 of 128 matches
Mail list logo
