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
