[
https://issues.apache.org/jira/browse/BEAM-8852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16988905#comment-16988905
]
Alexey Romanenko commented on BEAM-8852:
----------------------------------------
Yes, I think that current implementation of EOS sink in KafkaIO supports only
one output topic. So we can't use topic name from ProducerRecord since they
could be different and not even known in advance. Perhaps, we need add this
into javadoc and warn user more clearly about that.
> KafkaIO withEOS option does not use the topic provided in ProducerRecord
> ------------------------------------------------------------------------
>
> Key: BEAM-8852
> URL: https://issues.apache.org/jira/browse/BEAM-8852
> Project: Beam
> Issue Type: Bug
> Components: io-java-kafka
> Affects Versions: 2.15.0
> Reporter: DAVID MARTINEZ MATA
> Priority: Major
> Labels: eos, kafka
>
> Work In Progress.... defining the case accurately
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
