kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From vvcep...@apache.org
Subject [kafka] branch trunk updated (ed7c071 -> 71c5729)
Date Wed, 15 Jan 2020 15:40:14 GMT
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 ed7c071  KAFKA-9365: Add server side change  to include consumer group information
within transaction commit (#7897)
     add 71c5729  KAFKA-6144: Add KeyQueryMetadata APIs to KafkaStreams (#7960)

No new revisions were added by this update.

Summary of changes:
 .../org/apache/kafka/streams/KafkaStreams.java     |  41 +++-
 .../org/apache/kafka/streams/KeyQueryMetadata.java | 104 +++++++++++
 .../org/apache/kafka/streams/StreamsConfig.java    |   4 +-
 .../processor/internals/StreamsMetadataState.java  | 189 ++++++++++++++++---
 .../internals/StreamsPartitionAssignor.java        |  40 +++-
 .../streams/processor/internals/TaskManager.java   |   5 +-
 .../internals/assignment/AssignmentInfo.java       | 142 ++++++++++----
 .../StreamsAssignmentProtocolVersions.java         |   2 +-
 .../kafka/streams/state/StreamsMetadata.java       |  72 +++++--
 .../resources/common/message/SubscriptionInfo.json |   2 +-
 .../org/apache/kafka/streams/KafkaStreamsTest.java |  15 +-
 .../OptimizedKTableIntegrationTest.java            |   8 +-
 .../integration/QueryableStateIntegrationTest.java |  76 +++++---
 .../internals/StreamsMetadataStateTest.java        | 208 +++++++++++----------
 .../internals/StreamsPartitionAssignorTest.java    |  85 +++++++--
 .../internals/assignment/AssignmentInfoTest.java   |  92 +++++----
 .../assignment/LegacySubscriptionInfoSerde.java    |   4 +-
 .../internals/assignment/SubscriptionInfoTest.java |   4 +-
 .../kafka/streams/tests/StreamsUpgradeTest.java    |   2 +-
 .../tests/streams/streams_upgrade_test.py          |  16 +-
 20 files changed, 827 insertions(+), 284 deletions(-)
 create mode 100644 streams/src/main/java/org/apache/kafka/streams/KeyQueryMetadata.java


Mime
View raw message