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 612e1299e46 KAFKA-18230: Handle not controller or not leader error in
admin client (#18165)
add b998189b00a KAFKA-18538: Add Streams membership manager (#18551)
No new revisions were added by this update.
Summary of changes:
.../internals/AbstractMembershipManager.java | 2 +-
.../internals/StreamsMembershipManager.java | 1282 ++++++++++++
.../internals/StreamsMembershipManagerTest.java | 2186 ++++++++++++++++++++
3 files changed, 3469 insertions(+), 1 deletion(-)
create mode 100644
clients/src/main/java/org/apache/kafka/clients/consumer/internals/StreamsMembershipManager.java
create mode 100644
clients/src/test/java/org/apache/kafka/clients/consumer/internals/StreamsMembershipManagerTest.java
