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 3d7ac0c3d12 MINOR: Fix typos in multiple files (#19102)
add 017692e86c5 KAFKA-18887: Implement Streams Admin APIs (#19049)
No new revisions were added by this update.
Summary of changes:
.../java/org/apache/kafka/clients/admin/Admin.java | 97 +++
.../admin/AlterConsumerGroupOffsetsResult.java | 2 +-
...s.java => AlterStreamsGroupOffsetsOptions.java} | 6 +-
...lt.java => AlterStreamsGroupOffsetsResult.java} | 26 +-
....java => DeleteStreamsGroupOffsetsOptions.java} | 7 +-
...t.java => DeleteStreamsGroupOffsetsResult.java} | 35 +-
...ptions.java => DeleteStreamsGroupsOptions.java} | 5 +-
...sResult.java => DeleteStreamsGroupsResult.java} | 33 +-
.../kafka/clients/admin/ForwardingAdmin.java | 20 +
.../kafka/clients/admin/KafkaAdminClient.java | 33 +
...ns.java => ListStreamsGroupOffsetsOptions.java} | 11 +-
.../admin/ListStreamsGroupOffsetsResult.java | 58 ++
...tions.java => ListStreamsGroupOffsetsSpec.java} | 22 +-
.../kafka/clients/admin/KafkaAdminClientTest.java | 854 ++++++++++++++++++++-
.../kafka/clients/admin/MockAdminClient.java | 25 +
.../TestingMetricsInterceptingAdminClient.java | 29 +
16 files changed, 1190 insertions(+), 73 deletions(-)
copy
clients/src/main/java/org/apache/kafka/clients/admin/{ListShareGroupOffsetsOptions.java
=> AlterStreamsGroupOffsetsOptions.java} (82%)
copy
clients/src/main/java/org/apache/kafka/clients/admin/{DeleteRecordsResult.java
=> AlterStreamsGroupOffsetsResult.java} (56%)
copy
clients/src/main/java/org/apache/kafka/clients/admin/{AlterShareGroupOffsetsOptions.java
=> DeleteStreamsGroupOffsetsOptions.java} (80%)
copy
clients/src/main/java/org/apache/kafka/clients/admin/{DeleteGroupsResult.java
=> DeleteStreamsGroupOffsetsResult.java} (54%)
copy
clients/src/main/java/org/apache/kafka/clients/admin/{DeleteShareGroupsOptions.java
=> DeleteStreamsGroupsOptions.java} (83%)
copy
clients/src/main/java/org/apache/kafka/clients/admin/{DeleteGroupsResult.java
=> DeleteStreamsGroupsResult.java} (64%)
copy
clients/src/main/java/org/apache/kafka/clients/admin/{ListConsumerGroupOffsetsOptions.java
=> ListStreamsGroupOffsetsOptions.java} (71%)
create mode 100644
clients/src/main/java/org/apache/kafka/clients/admin/ListStreamsGroupOffsetsResult.java
copy
clients/src/main/java/org/apache/kafka/clients/admin/{DescribeClassicGroupsOptions.java
=> ListStreamsGroupOffsetsSpec.java} (60%)
