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 655843c KAFKA-9386; Apply delete ACL filters to resources from filter even if not
in cache (#7911)
add e9cde11 KAFKA-9383: Expose consumer group metadata (#7906)
No new revisions were added by this update.
Summary of changes:
.../apache/kafka/clients/consumer/Consumer.java | 5 ++
.../clients/consumer/ConsumerGroupMetadata.java | 13 ++--
.../kafka/clients/consumer/KafkaConsumer.java | 10 +++
.../kafka/clients/consumer/MockConsumer.java | 5 ++
.../consumer/internals/ConsumerCoordinator.java | 18 +++++-
.../consumer/ConsumerGroupMetadataTest.java | 38 +++++------
.../kafka/clients/consumer/KafkaConsumerTest.java | 74 ++++++++++++++--------
.../kafka/clients/consumer/MockConsumerTest.java | 4 +-
.../internals/ConsumerCoordinatorTest.java | 24 ++++++-
9 files changed, 135 insertions(+), 56 deletions(-)
copy connect/runtime/src/test/java/org/apache/kafka/connect/util/TableTest.java => clients/src/test/java/org/apache/kafka/clients/consumer/ConsumerGroupMetadataTest.java
(54%)
|