You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@kafka.apache.org by mj...@apache.org on 2020/05/28 01:41:45 UTC

[kafka] branch trunk updated (9c833f6 -> 90045f6)

This is an automated email from the ASF dual-hosted git repository.

mjsax pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.


    from 9c833f6  KAFKA-9960: implement KIP-606 to add metadata context to MetricsReporter (#8691)
     add 90045f6  KAFKA-9146: Add option to force delete active members in StreamsResetter (#8589)

No new revisions were added by this update.

Summary of changes:
 .../kafka/clients/admin/KafkaAdminClient.java      |  46 +++++---
 .../RemoveMembersFromConsumerGroupOptions.java     |  12 +++
 .../RemoveMembersFromConsumerGroupResult.java      |  26 ++++-
 .../kafka/clients/admin/KafkaAdminClientTest.java  |  62 +++++++++++
 .../RemoveMembersFromConsumerGroupOptionsTest.java |   4 +
 .../main/scala/kafka/tools/StreamsResetter.java    |  32 ++++--
 .../kafka/api/PlaintextAdminIntegrationTest.scala  | 116 ++++++++++++++-------
 .../integration/AbstractResetIntegrationTest.java  |  52 ++++++++-
 .../streams/integration/ResetIntegrationTest.java  |   5 +
 .../integration/utils/IntegrationTestUtils.java    |  25 +++--
 10 files changed, 302 insertions(+), 78 deletions(-)