John Casey created BEAM-13852:
---------------------------------
Summary: KafkaIO.read.withDynamicRead() doesn't pick up new
TopicPartitions
Key: BEAM-13852
URL: https://issues.apache.org/jira/browse/BEAM-13852
Project: Beam
Issue Type: Bug
Components: io-java-kafka
Reporter: John Casey
Assignee: John Casey
KafkaIO.Read().withDynamicRead() is correctly pulling messages from existing
topics, but isn't picking up new topics or partitions when they are created.
Currently, this appears to be an interaction between the timer configuration,
and the duration of the operating window, that is causing the problem
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
