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 8b4560e3f0f KAFKA-15767 Refactor TransactionManager to avoid use of
ThreadLocal (#19440)
add 3fae785ea0b KAFKA-19110: Add missing unit test for Streams-consumer
integration (#19457)
No new revisions were added by this update.
Summary of changes:
.../internals/StreamsMembershipManager.java | 7 +
.../consumer/internals/AsyncKafkaConsumerTest.java | 55 +++-
.../consumer/internals/RequestManagersTest.java | 54 +++-
.../StreamsGroupHeartbeatRequestManagerTest.java | 30 ++
.../events/ApplicationEventProcessorTest.java | 99 ++++++
.../streams/processor/internals/StreamThread.java | 6 +-
.../DefaultStreamsRebalanceListenerTest.java | 208 +++++++++++++
.../processor/internals/StreamThreadTest.java | 332 +++++++++++++++++++++
8 files changed, 786 insertions(+), 5 deletions(-)
create mode 100644
streams/src/test/java/org/apache/kafka/streams/processor/internals/DefaultStreamsRebalanceListenerTest.java
