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/15 15:40:14 UTC
[kafka] branch trunk updated (ed7c071 -> 71c5729)
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