kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject [kafka] branch trunk updated (277e4cd -> 9d52dec)
Date Fri, 29 May 2020 17:48:51 GMT
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(-)


Mime
View raw message