You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by mj...@apache.org on 2022/03/31 16:50:42 UTC
[kafka] branch trunk updated (3c279b6 -> 6b2a0bc)
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 3c279b6 fix: make sliding window works without grace period (#kafka-13739) (#11928)
add 6b2a0bc KAFKA-13785: add processor metadata to be committed with offset (#11829)
No new revisions were added by this update.
Summary of changes:
.../internals/AbstractProcessorContext.java | 23 +++
.../internals/InternalProcessorContext.java | 9 +
.../processor/internals/ProcessorMetadata.java | 145 ++++++++++++++++
.../streams/processor/internals/StreamTask.java | 96 +++++-----
.../internals/TopicPartitionMetadata.java | 113 ++++++++++++
.../internals/ProcessorContextImplTest.java | 33 ++++
.../processor/internals/ProcessorMetadataTest.java | 163 +++++++++++++++++
.../processor/internals/StreamTaskTest.java | 193 ++++++++++++++++-----
.../internals/TopicPartitionMetadataTest.java | 106 +++++++++++
.../test/MockInternalNewProcessorContext.java | 26 +++
.../kafka/test/MockInternalProcessorContext.java | 26 +++
.../java/org/apache/kafka/test/MockProcessor.java | 8 +
12 files changed, 842 insertions(+), 99 deletions(-)
create mode 100644 streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorMetadata.java
create mode 100644 streams/src/main/java/org/apache/kafka/streams/processor/internals/TopicPartitionMetadata.java
create mode 100644 streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorMetadataTest.java
create mode 100644 streams/src/test/java/org/apache/kafka/streams/processor/internals/TopicPartitionMetadataTest.java