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 71113b4 MINOR: Code cleanup to improve generic typing (#8251)
add d3c7ef2 KAFKA-9451: Update MockConsumer to support
ConsumerGroupMetadata
No new revisions were added by this update.
Summary of changes:
.../clients/consumer/ConsumerGroupMetadata.java | 17 +++
.../kafka/clients/consumer/MockConsumer.java | 4 +-
.../kafka/clients/producer/MockProducer.java | 2 +-
.../kafka/clients/consumer/MockConsumerTest.java | 5 +-
.../streams/processor/internals/StreamThread.java | 25 ++--
.../processor/internals/ActiveTaskCreatorTest.java | 155 +++++++++++++++++++++
.../processor/internals/TaskManagerTest.java | 1 -
.../StreamThreadStateStoreProviderTest.java | 2 +-
8 files changed, 193 insertions(+), 18 deletions(-)
create mode 100644
streams/src/test/java/org/apache/kafka/streams/processor/internals/ActiveTaskCreatorTest.java
