[GitHub] [kafka] ableegoldman commented on a change in pull request #10840: KAFKA-12849: KIP-744 TaskMetadata ThreadMetadata StreamsMetadata as API

2021-06-23 Thread GitBox
ableegoldman commented on a change in pull request #10840: URL: https://github.com/apache/kafka/pull/10840#discussion_r657560587 ## File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java ## @@ -1558,12 +1607,45 @@ private void processStreamThread(final

[GitHub] [kafka] ableegoldman commented on a change in pull request #10840: KAFKA-12849: KIP-744 TaskMetadata ThreadMetadata StreamsMetadata as API

2021-06-22 Thread GitBox
ableegoldman commented on a change in pull request #10840: URL: https://github.com/apache/kafka/pull/10840#discussion_r656694680 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskMetadataImpl.java ## @@ -0,0 +1,105 @@ +/* + * Licensed to the