C0urante commented on code in PR #12561:
URL: https://github.com/apache/kafka/pull/12561#discussion_r1002789963
##########
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/distributed/WorkerCoordinatorIncrementalTest.java:
##########
@@ -517,13 +517,13 @@ public void testTaskAssignmentWhenWorkerBounces() {
leaderAssignment = deserializeAssignment(result, leaderId);
assertAssignment(leaderId, offset,
Collections.emptyList(), 0,
- Collections.emptyList(), 0,
+ Collections.emptyList(), 1,
Review Comment:
Hi @vamossagar12--sorry for the delay. I've filed the follow-up PR here:
https://github.com/vamossagar12/kafka/pull/1
I've marked it as a draft since it should not be merged into your
KAFKA-12495 branch until it's approved to be merged into trunk here, but it's
ready for review now. Can you take a look and see what you think? If it looks
alright, we can ask Luke to take a look.
(cc @showuon)
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
