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 2022/01/11 00:11:23 UTC

[kafka] branch trunk updated (1785e12 -> c182a43)

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 1785e12  KAFKA-13582: TestVerifiableProducer.test_multiple_kraft_security_protocols fails (#11664)
     add c182a43  MINOR: prefix topics if internal config is set (#11611)

No new revisions were added by this update.

Summary of changes:
 .../org/apache/kafka/streams/StreamsConfig.java     | 12 ++++++++++++
 .../internals/InternalTopologyBuilder.java          | 18 +++++++++++++++---
 .../processor/internals/ProcessorContextUtils.java  | 21 +++++++++++++++++++--
 .../processor/internals/ProcessorStateManager.java  |  6 +++---
 .../streams/state/internals/CachingWindowStore.java |  8 +++++++-
 .../InMemoryTimeOrderedKeyValueBuffer.java          |  8 +++++++-
 .../state/internals/MeteredKeyValueStore.java       | 19 +++++++++++++++++--
 .../state/internals/MeteredSessionStore.java        | 19 +++++++++++++++++--
 .../streams/state/internals/MeteredWindowStore.java | 15 +++++++++++++--
 .../integration/NamedTopologyIntegrationTest.java   | 21 ++++++++++++---------
 .../internals/GlobalStateStoreProviderTest.java     |  4 ++++
 .../MeteredTimestampedKeyValueStoreTest.java        |  3 +++
 12 files changed, 129 insertions(+), 25 deletions(-)