[
https://issues.apache.org/jira/browse/BEAM-3703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz updated BEAM-3703:
---
Description:
I am trying to read from file and write to Kafka in google cloud kafka and
gettin
[
https://issues.apache.org/jira/browse/BEAM-3703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kenneth Knowles updated BEAM-3703:
--
Component/s: runner-flink
> java.io.IOException: KafkaWriter : failed to send 1 records (since la
[
https://issues.apache.org/jira/browse/BEAM-3703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kenneth Knowles updated BEAM-3703:
--
Component/s: (was: beam-model)
io-java-kafka
> java.io.IOException: KafkaWri