kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From mj...@apache.org
Subject [kafka] branch trunk updated (89f1bea -> 9565a52)
Date Mon, 09 Aug 2021 22:20:56 GMT
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 89f1bea  KAFKA-13165: Validate KRaft node id, process role and quorum voters (#11179)
     add 9565a52  KAFKA-12779: rename namedTopology in TaskId to topologyName #11192

No new revisions were added by this update.

Summary of changes:
 .../org/apache/kafka/streams/processor/TaskId.java | 30 +++++++++++-----------
 .../processor/internals/ActiveTaskCreator.java     |  3 +--
 .../processor/internals/ProcessorContextUtils.java |  4 +--
 .../processor/internals/StandbyTaskCreator.java    |  2 +-
 .../processor/internals/StateDirectory.java        |  2 +-
 .../internals/StreamsPartitionAssignor.java        |  4 +--
 .../streams/processor/internals/TaskManager.java   |  2 +-
 .../processor/internals/TopologyMetadata.java      |  2 +-
 .../assignment/ConsumerProtocolUtils.java          | 16 ++++++------
 .../internals/assignment/SubscriptionInfo.java     |  6 ++---
 .../state/internals/CachingWindowStore.java        |  2 +-
 .../InMemoryTimeOrderedKeyValueBuffer.java         |  2 +-
 .../state/internals/MeteredKeyValueStore.java      |  4 +--
 .../state/internals/MeteredSessionStore.java       |  4 +--
 .../state/internals/MeteredWindowStore.java        |  4 +--
 .../internals/AbstractProcessorContextTest.java    |  2 +-
 .../internals/ProcessorStateManagerTest.java       |  6 ++---
 .../processor/internals/StandbyTaskTest.java       |  4 +--
 .../state/internals/MeteredKeyValueStoreTest.java  |  2 +-
 .../state/internals/MeteredSessionStoreTest.java   |  2 +-
 .../MeteredTimestampedKeyValueStoreTest.java       |  2 +-
 .../MeteredTimestampedWindowStoreTest.java         |  2 +-
 .../state/internals/MeteredWindowStoreTest.java    |  2 +-
 .../apache/kafka/test/NoOpProcessorContext.java    |  2 +-
 24 files changed, 55 insertions(+), 56 deletions(-)

Mime
View raw message