Bruno Cadonna

@mdedetrich Some of our discussions on this PR are still unresolved. Did you forget to push some commits?

@mdedetrich I answered your question about `InOrder`. Sorry, I somehow missed that. Note that I unresolved other two comments: https://github.com/apache/kafka/pull/12524/files#r984332259 https://github.com/apache/kafka/pull/12524/files#r984332539 Let me know if my comments are not clear.

Build failures are unrelated: ``` Build / JDK 11 and Scala 2.13 / org.apache.kafka.controller.QuorumControllerTest.testBalancePartitionLeaders() Build / JDK 8 and Scala 2.12 / org.apache.kafka.controller.QuorumControllerTest.testDelayedConfigurationOperations() ```

The test failures are unrelated: ``` Build / JDK 8 and Scala 2.12 / org.apache.kafka.controller.QuorumControllerTest.testDelayedConfigurationOperations() Build / JDK 11 and Scala 2.13 / kafka.api.TransactionsTest.testFailureToFenceEpoch(String).quorum=kraft Build / JDK 17 and Scala...

@divijvaidya @jsancio The Streams related changes LGTM!

@clolov Thank you for your interest and help! Since this PR was not touched more than half a year, I would be fine to close it and you can open...

@wycccccc Do you plan to still work on this PR?

Failures are unrelated: ``` Build / JDK 8 and Scala 2.12 / org.apache.kafka.clients.consumer.CooperativeStickyAssignorTest.testLargeAssignmentAndGroupWithNonEqualSubscription() Build / JDK 8 and Scala 2.12 / org.apache.kafka.clients.consumer.StickyAssignorTest.testLargeAssignmentAndGroupWithNonEqualSubscription() Build / JDK 8 and Scala 2.12 /...

@clolov What is the status of this PR?

I restarted the builds to ensure everything is still fine with current trunk since they were run 18 days ago last time. If the builds are acceptable, I will merge...