You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@kafka.apache.org by vv...@apache.org on 2020/01/16 22:26:11 UTC

[kafka] branch trunk updated (fbe2e60 -> bbd3348)

This is an automated email from the ASF dual-hosted git repository.

vvcephei pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.


    from fbe2e60  KAFKA-9235; Ensure transaction coordinator is stopped after replica deletion (#7963)
     add bbd3348  KAFKA-9431: Expose API in KafkaStreams to fetch all local offset lags (#7961)

No new revisions were added by this update.

Summary of changes:
 .../org/apache/kafka/streams/KafkaStreams.java     |  80 ++++++
 .../java/org/apache/kafka/streams/LagInfo.java     |  91 ++++++
 .../streams/processor/internals/AbstractTask.java  |   1 -
 .../processor/internals/AssignedStreamsTasks.java  |   5 +-
 .../streams/processor/internals/AssignedTasks.java |   2 +-
 .../internals/InternalTopologyBuilder.java         |   9 +
 .../processor/internals/ProcessorStateManager.java |  14 +-
 .../streams/processor/internals/StandbyTask.java   |   6 +
 .../processor/internals/StoreChangelogReader.java  |   3 +-
 .../streams/processor/internals/StreamTask.java    |   4 +
 .../streams/processor/internals/StreamThread.java  |  12 +
 .../processor/internals/StreamsMetadataState.java  |   4 +
 .../streams/processor/internals/TaskManager.java   |  12 +
 .../org/apache/kafka/streams/KafkaStreamsTest.java |  30 ++
 .../integration/LagFetchIntegrationTest.java       | 311 +++++++++++++++++++++
 .../integration/QueryableStateIntegrationTest.java |  29 ++
 16 files changed, 606 insertions(+), 7 deletions(-)
 create mode 100644 streams/src/main/java/org/apache/kafka/streams/LagInfo.java
 create mode 100644 streams/src/test/java/org/apache/kafka/streams/integration/LagFetchIntegrationTest.java