This is an automated email from the ASF dual-hosted git repository.
ableegoldman pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from db3e5e2 Rework on KAFKA-3968: fsync the parent directory of a segment
file when the file is created (#10680)
add f2785f3 KAFKA-12754: Improve endOffsets for TaskMetadata (#10634)
No new revisions were added by this update.
Summary of changes:
.../kafka/streams/processor/TaskMetadata.java | 9 +
.../streams/processor/internals/StandbyTask.java | 5 -
.../streams/processor/internals/StreamTask.java | 16 +-
.../streams/processor/internals/StreamThread.java | 10 ++
.../kafka/streams/processor/internals/Task.java | 7 -
.../streams/processor/internals/TaskManager.java | 26 ++-
.../integration/TaskMetadataIntegrationTest.java | 200 +++++++++++++++++++++
.../processor/internals/StreamTaskTest.java | 9 +-
.../processor/internals/TaskManagerTest.java | 7 -
9 files changed, 254 insertions(+), 35 deletions(-)
create mode 100644
streams/src/test/java/org/apache/kafka/streams/integration/TaskMetadataIntegrationTest.java
