[BEAM-12193] WatchKafkaTopicPartitionDoFn reports user counter to indicate which TopicPartition has been emitted to downstream

• Type: Improvement
• Status: Resolved
• Priority: P2
• Resolution: Fixed
• Fix Version/s: 2.30.0
• Component/s: io-java-kafka
• Assignee: Boyuan Zhang
• Reporter: Boyuan Zhang
• Created: 19/Apr/21 17:54
• Updated: 26/Apr/21 09:50
• Resolved: 26/Apr/21 09:50

Description

WatchKafkaTopicPartitionDoFn can use user counter to indicate which TopicPartition has been outputted to downstream.

Issue Links

• links to: GitHub Pull Request #14570