[jira] [Updated] (BEAM-6751) KafkaIO's EOS mode does not work with FlinkRunner

[ https://issues.apache.org/jira/browse/BEAM-6751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-6751: -- Description: KafkaIO has a validation check to allow only certain runners capable of provide ex

[jira] [Updated] (BEAM-6751) KafkaIO's EOS mode does not work with FlinkRunner

[ https://issues.apache.org/jira/browse/BEAM-6751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-6751: - Priority: Major (was: Critical) > KafkaIO's EOS mode does not work with FlinkRunner > ---

[jira] [Updated] (BEAM-6751) KafkaIO's EOS mode does not work with FlinkRunner

[ https://issues.apache.org/jira/browse/BEAM-6751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-6751: - Description: KafkaIO has a validation check which whitelists certain runners capable of p

[jira] [Updated] (BEAM-6751) KafkaIO's EOS mode does not work with FlinkRunner

[ https://issues.apache.org/jira/browse/BEAM-6751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-6751: - Summary: KafkaIO's EOS mode does not work with FlinkRunner (was: KafkaIO blocks FlinkRunn