kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From mj...@apache.org
Subject [kafka] branch trunk updated (9c833f6 -> 90045f6)
Date Thu, 28 May 2020 01:41:45 GMT
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(-)


Mime
View raw message