You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by gu...@apache.org on 2020/05/29 17:48:51 UTC
[kafka] branch trunk updated (277e4cd -> 9d52dec)
This is an automated email from the ASF dual-hosted git repository.
guozhang pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 277e4cd KAFKA-10056; Ensure consumer metadata contains new topics on subscription change (#8739)
add 9d52dec KAFKA-9501: convert between active and standby without closing stores (#8248)
No new revisions were added by this update.
Summary of changes:
checkstyle/suppressions.xml | 9 +-
.../org/apache/kafka/streams/StreamsConfig.java | 4 +-
.../internals/AbstractProcessorContext.java | 3 +-
.../processor/internals/ActiveTaskCreator.java | 136 ++++++++++-----
.../processor/internals/ChangelogReader.java | 7 -
.../processor/internals/ChangelogRegister.java | 8 +
.../internals/GlobalProcessorContextImpl.java | 18 +-
.../internals/InternalProcessorContext.java | 16 ++
.../processor/internals/ProcessorContextImpl.java | 72 ++++----
.../processor/internals/ProcessorStateManager.java | 121 ++++++++++---
.../streams/processor/internals/StandbyTask.java | 40 ++++-
.../processor/internals/StandbyTaskCreator.java | 74 ++++++--
.../processor/internals/StateManagerUtil.java | 20 +--
.../processor/internals/StoreChangelogReader.java | 33 +++-
.../streams/processor/internals/StreamTask.java | 47 +++--
.../kafka/streams/processor/internals/Task.java | 5 +
.../streams/processor/internals/TaskManager.java | 49 ++++--
.../state/internals/CachingKeyValueStore.java | 22 ++-
.../state/internals/CachingSessionStore.java | 24 ++-
.../state/internals/CachingWindowStore.java | 32 ++--
.../InMemoryTimeOrderedKeyValueBuffer.java | 41 +++--
.../kafka/streams/TopologyTestDriverWrapper.java | 2 +-
.../integration/InternalTopicIntegrationTest.java | 4 +-
.../OptimizedKTableIntegrationTest.java | 39 +----
.../integration/RestoreIntegrationTest.java | 188 +++++++++++++++-----
.../integration/utils/IntegrationTestUtils.java | 189 +++++++++++++++------
.../internals/AbstractProcessorContextTest.java | 13 ++
.../processor/internals/MockChangelogReader.java | 2 +-
.../internals/ProcessorContextImplTest.java | 14 +-
.../processor/internals/ProcessorContextTest.java | 3 +-
.../internals/ProcessorStateManagerTest.java | 86 +++++++++-
.../processor/internals/StandbyTaskTest.java | 39 ++++-
.../processor/internals/StateManagerUtilTest.java | 27 +--
.../internals/StoreChangelogReaderTest.java | 6 +-
.../processor/internals/StreamTaskTest.java | 100 ++++++++---
.../processor/internals/TaskManagerTest.java | 22 +--
.../AbstractRocksDBSegmentedBytesStoreTest.java | 2 +-
.../StreamThreadStateStoreProviderTest.java | 18 +-
.../kafka/test/InternalMockProcessorContext.java | 32 +++-
.../kafka/test/MockInternalProcessorContext.java | 14 ++
.../apache/kafka/test/NoOpProcessorContext.java | 17 ++
.../apache/kafka/streams/TopologyTestDriver.java | 16 +-
42 files changed, 1149 insertions(+), 465 deletions(-)