This is an automated email from the ASF dual-hosted git repository.
lucasbru pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from 80eb86e18e9 KAFKA-19418: Fix for flaky verifiable producer system test
(#20001)
add a797d644bc5 KAFKA-19244: Add support for kafka-streams-groups.sh
options (reset-offsets) [1/N] (#19646)
No new revisions were added by this update.
Summary of changes:
.../clients/admin/ListStreamsGroupOffsetsSpec.java | 4 +-
.../java/org/apache/kafka/tools/OffsetsUtils.java | 474 ++++++++++++
.../tools/consumer/group/ConsumerGroupCommand.java | 375 +--------
.../kafka/tools/consumer/group/CsvUtils.java | 4 +-
.../kafka/tools/streams/StreamsGroupCommand.java | 842 +++++++++++++--------
.../tools/streams/StreamsGroupCommandOptions.java | 225 ++++--
.../streams/DeleteStreamsGroupOffsetTest.java | 2 +-
.../tools/streams/DeleteStreamsGroupTest.java | 176 ++++-
.../tools/streams/DescribeStreamsGroupTest.java | 22 +-
.../tools/streams/ResetStreamsGroupOffsetTest.java | 743 ++++++++++++++++++
.../tools/streams/StreamsGroupCommandTest.java | 255 +++++--
11 files changed, 2321 insertions(+), 801 deletions(-)
create mode 100644 tools/src/main/java/org/apache/kafka/tools/OffsetsUtils.java
create mode 100644
tools/src/test/java/org/apache/kafka/tools/streams/ResetStreamsGroupOffsetTest.java
