fvaleri commented on code in PR #13562:
URL: https://github.com/apache/kafka/pull/13562#discussion_r1271258247
##
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
+ * contri
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: jira-unsubscr...@kafka.apache.
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 respon
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 >
StoreQueryIntegrati
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 t
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 Foundatio
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 Foundatio
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 Foundatio
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 Foundatio
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 Foundatio
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
countingOperat
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 (ASF)
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()
ā
org.apache.kafka.connect.mirror.integration.MirrorConnectorsIntegrationExactlyOnceTe
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 coul
[
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 assignme
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: jira-unsubscr...@kafka.apache.o
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 RackAwareTaskAssign
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 validateClientRack
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) {
// VisibleForTesti
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 commi
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 bu
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 bu
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": "0+",
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 perfor
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 {
*/
p
[
https://issues.apache.org/jira/browse/KAFKA-15132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17745705#comment-17745705
]
Mehari Beyene commented on KAFKA-15132:
---
KIP:
https://cwiki.apache.org/confluence
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 se
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 Foundatio
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, please
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 Logge
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 re
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 Foundatio
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+", "ty
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: jira-unsubscr...@kafka.apache
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 org.apache.kafka.coordin
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
AssignmentSpec
[
https://issues.apache.org/jira/browse/KAFKA-15116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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&focusedCommentId=17745690#comment-17745690
]
Matthias J. Sax commented on KAFKA-15116:
-
{quote}The internal store is shared a
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: jira-unsubscr...@kafka.apache.or
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 to
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: jira-unsubscr...@kafka.apache.or
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 to
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 newGroupMetadat
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 newGroupMetadat
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 newGroupMetadat
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 newGroupMetadat
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) {
// VisibleForTesti
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
updateStaticMem
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 newGroupMetadat
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 newGroupMetadat
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 newGroupMetadat
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 newGroupMetadat
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 on
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 ab
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 nee
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
+ * contri
[
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
testLargeAssignmentAndGroup
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: jira-unsubscr...@kafka.apache
[
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 for
[
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&focusedCommentId=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
+ * contri
[
https://issues.apache.org/jira/browse/KAFKA-15231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17745620#comment-17745620
]
Jorge Esteban Quilcate Otoya commented on KAFKA-15231:
--
Thanks [~di
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 an
[
https://issues.apache.org/jira/browse/KAFKA-15231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17745602#comment-17745602
]
Divij Vaidya commented on KAFKA-15231:
--
Hey [~jeqo]Ā
If the RSM is unavailable (for
[
https://issues.apache.org/jira/browse/KAFKA-15231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17745600#comment-17745600
]
Jorge Esteban Quilcate Otoya commented on KAFKA-15231:
--
cc [~satish
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 m
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
test
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 m
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 remo
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 Ty
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 m
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 automated
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]
/home/jenkins/jen
1 - 100 of 129 matches
Mail list logo
