1 file changed
+1
-1
lines changedDiff for: upstream
- clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumer.java+22-8
- clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerDelegateCreator.java+2-1
- clients/src/main/java/org/apache/kafka/clients/consumer/internals/RequestManagers.java+69-24
- clients/src/main/java/org/apache/kafka/clients/consumer/internals/StreamsGroupHeartbeatRequestManager.java+18-3
- clients/src/main/java/org/apache/kafka/clients/consumer/internals/StreamsRebalanceData.java+1-4
- clients/src/main/java/org/apache/kafka/clients/consumer/internals/StreamsRebalanceEventsProcessor.java+7-6
- clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/ApplicationEventProcessor.java+78-19
- clients/src/test/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumerTest.java+9-3
- clients/src/test/java/org/apache/kafka/clients/consumer/internals/RequestManagersTest.java+3-1
- clients/src/test/java/org/apache/kafka/clients/consumer/internals/StreamsRebalanceEventsProcessorTest.java+12-6
- clients/src/test/java/org/apache/kafka/clients/consumer/internals/events/ApplicationEventProcessorTest.java+4-1
- streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/SmokeTestDriverIntegrationTest.java+37-7
- streams/src/main/java/org/apache/kafka/streams/GroupProtocol.java+43
- streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java+24
- streams/src/main/java/org/apache/kafka/streams/processor/internals/DefaultStreamsGroupRebalanceCallbacks.java+130
- streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java+221-8
- streams/src/test/java/org/apache/kafka/streams/StreamsConfigTest.java+20
- streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamThreadTest.java+30
- streams/src/test/java/org/apache/kafka/streams/tests/SmokeTestClient.java+3-1
0 commit comments