You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by da...@apache.org on 2021/02/11 11:07:39 UTC
[kafka] branch trunk updated (39dcdef -> 202ff63)
This is an automated email from the ASF dual-hosted git repository.
dajac pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 39dcdef MINOR: Prevent creating partition.metadata until ID can be written (#10041)
add 202ff63 KAFKA-5235: GetOffsetShell: Support for multiple topics and consumer configuration override (KIP-635) (#9430)
No new revisions were added by this update.
Summary of changes:
bin/{kafka-features.sh => kafka-get-offsets.sh} | 6 +-
.../{kafka-configs.bat => kafka-get-offsets.bat} | 2 +-
.../main/scala/kafka/tools/GetOffsetShell.scala | 230 ++++++++++++++-------
.../kafka/tools/GetOffsetShellParsingTest.scala | 207 +++++++++++++++++++
.../scala/kafka/tools/GetOffsetShellTest.scala | 207 +++++++++++++++++++
tests/kafkatest/services/kafka/kafka.py | 14 +-
.../kafkatest/tests/core/get_offset_shell_test.py | 196 ++++++++++++++++--
7 files changed, 762 insertions(+), 100 deletions(-)
copy bin/{kafka-features.sh => kafka-get-offsets.sh} (91%)
copy bin/windows/{kafka-configs.bat => kafka-get-offsets.bat} (93%)
create mode 100644 core/src/test/scala/kafka/tools/GetOffsetShellParsingTest.scala
create mode 100644 core/src/test/scala/kafka/tools/GetOffsetShellTest.scala