This is an automated email from the ASF dual-hosted git repository.
cadonna pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from a3da6bbb0c6 MINOR: Cleanup ControllerCOntext and StateChangeLogger
(#18588)
add 239708f52ec KAFKA-18518: Add processor to handle rebalance events
(#18527)
No new revisions were added by this update.
Summary of changes:
.../internals/StreamsGroupRebalanceCallbacks.java | 29 +-
.../consumer/internals/StreamsRebalanceData.java | 266 ++++++++++++++++++
.../internals/StreamsRebalanceEventsProcessor.java | 205 ++++++++++++++
.../internals/events/ApplicationEvent.java | 3 +
.../consumer/internals/events/BackgroundEvent.java | 7 +-
...reamsOnAllTasksLostCallbackCompletedEvent.java} | 26 +-
... StreamsOnAllTasksLostCallbackNeededEvent.java} | 11 +-
...eamsOnTasksAssignedCallbackCompletedEvent.java} | 26 +-
...StreamsOnTasksAssignedCallbackNeededEvent.java} | 22 +-
...reamsOnTasksRevokedCallbackCompletedEvent.java} | 26 +-
... StreamsOnTasksRevokedCallbackNeededEvent.java} | 27 +-
.../internals/StreamsRebalanceDataTest.java | 305 +++++++++++++++++++++
.../StreamsRebalanceEventsProcessorTest.java | 267 ++++++++++++++++++
13 files changed, 1116 insertions(+), 104 deletions(-)
copy
group-coordinator/group-coordinator-api/src/main/java/org/apache/kafka/coordinator/group/api/assignor/MemberSubscription.java
=>
clients/src/main/java/org/apache/kafka/clients/consumer/internals/StreamsGroupRebalanceCallbacks.java
(51%)
create mode 100644
clients/src/main/java/org/apache/kafka/clients/consumer/internals/StreamsRebalanceData.java
create mode 100644
clients/src/main/java/org/apache/kafka/clients/consumer/internals/StreamsRebalanceEventsProcessor.java
copy
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/{ConsumerRebalanceListenerCallbackCompletedEvent.java
=> StreamsOnAllTasksLostCallbackCompletedEvent.java} (55%)
copy
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/{AllTopicsMetadataEvent.java
=> StreamsOnAllTasksLostCallbackNeededEvent.java} (72%)
copy
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/{ConsumerRebalanceListenerCallbackCompletedEvent.java
=> StreamsOnTasksAssignedCallbackCompletedEvent.java} (55%)
copy
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/{ShareFetchEvent.java
=> StreamsOnTasksAssignedCallbackNeededEvent.java} (58%)
copy
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/{ConsumerRebalanceListenerCallbackCompletedEvent.java
=> StreamsOnTasksRevokedCallbackCompletedEvent.java} (55%)
copy
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/{ShareSubscriptionChangeEvent.java
=> StreamsOnTasksRevokedCallbackNeededEvent.java} (56%)
create mode 100644
clients/src/test/java/org/apache/kafka/clients/consumer/internals/StreamsRebalanceDataTest.java
create mode 100644
clients/src/test/java/org/apache/kafka/clients/consumer/internals/StreamsRebalanceEventsProcessorTest.java
