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 b0fd308 KAFKA-9344: Override default values inside ConsumerConfigs
(#7876)
add 71113b4 MINOR: Code cleanup to improve generic typing (#8251)
No new revisions were added by this update.
Summary of changes:
.../internals/AbstractProcessorContext.java | 10 +--
.../internals/GlobalProcessorContextImpl.java | 18 ++---
.../processor/internals/GlobalStateUpdateTask.java | 9 ++-
.../internals/InternalProcessorContext.java | 7 +-
.../internals/InternalTopologyBuilder.java | 88 ++++++++++----------
.../processor/internals/PartitionGroup.java | 2 +-
.../processor/internals/ProcessorContextImpl.java | 43 +++++-----
.../internals/ProcessorNodePunctuator.java | 2 +-
.../processor/internals/ProcessorStateManager.java | 1 +
.../processor/internals/ProcessorTopology.java | 22 ++---
.../processor/internals/RecordDeserializer.java | 6 +-
.../streams/processor/internals/RecordQueue.java | 6 +-
.../processor/internals/StateManagerUtil.java | 5 +-
.../streams/processor/internals/StreamTask.java | 16 ++--
.../streams/processor/internals/StreamThread.java | 6 +-
.../kafka/streams/processor/internals/Task.java | 2 +-
.../org/apache/kafka/streams/KafkaStreamsTest.java | 9 ++-
.../apache/kafka/streams/StreamsBuilderTest.java | 9 +--
.../kafka/streams/TopologyTestDriverWrapper.java | 6 +-
.../EOSUncleanShutdownIntegrationTest.java | 6 +-
.../internals/InternalStreamsBuilderTest.java | 17 ++--
.../streams/kstream/internals/KStreamImplTest.java | 11 ++-
.../internals/GlobalProcessorContextImplTest.java | 5 +-
.../processor/internals/GlobalStateTaskTest.java | 16 ++--
.../internals/InternalTopologyBuilderTest.java | 93 ++++++++++++----------
.../internals/ProcessorTopologyFactories.java | 4 +-
.../processor/internals/ProcessorTopologyTest.java | 22 +++--
.../processor/internals/StreamTaskTest.java | 44 +++++-----
.../processor/internals/StreamThreadTest.java | 21 ++++-
.../processor/internals/StreamsProducerTest.java | 8 +-
.../processor/internals/TaskManagerTest.java | 19 +++--
.../kafka/test/InternalMockProcessorContext.java | 13 ++-
32 files changed, 284 insertions(+), 262 deletions(-)
