[jira] [Commented] (BEAM-3788) Implement a Kafka IO for Python SDK

[ https://issues.apache.org/jira/browse/BEAM-3788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17117906#comment-17117906 ] Chamikara Madhusanka Jayalath commented on BEAM-3788: - KafkaIO is expected to be

[jira] [Commented] (BEAM-3788) Implement a Kafka IO for Python SDK

[ https://issues.apache.org/jira/browse/BEAM-3788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17059941#comment-17059941 ] Nicolae Rosia commented on BEAM-3788: - until this is fixed, is there a way to implement an unbounded

[jira] [Commented] (BEAM-3788) Implement a Kafka IO for Python SDK

[ https://issues.apache.org/jira/browse/BEAM-3788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17041230#comment-17041230 ] Brian Hulette commented on BEAM-3788: - [~chadrik] for the coder issue: I'm +1 on the approach you

[jira] [Commented] (BEAM-3788) Implement a Kafka IO for Python SDK

[ https://issues.apache.org/jira/browse/BEAM-3788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17040565#comment-17040565 ] Chamikara Madhusanka Jayalath commented on BEAM-3788: - Added a comment to the email

[jira] [Commented] (BEAM-3788) Implement a Kafka IO for Python SDK

[ https://issues.apache.org/jira/browse/BEAM-3788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17040558#comment-17040558 ] Chad Dombrova commented on BEAM-3788: - Unless something has changed recently,

[jira] [Commented] (BEAM-3788) Implement a Kafka IO for Python SDK

[ https://issues.apache.org/jira/browse/BEAM-3788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17036376#comment-17036376 ] Chamikara Madhusanka Jayalath commented on BEAM-3788: - We are actively working on

[jira] [Commented] (BEAM-3788) Implement a Kafka IO for Python SDK

[ https://issues.apache.org/jira/browse/BEAM-3788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16982762#comment-16982762 ] Jing Chen commented on BEAM-3788: - i am curious if there is a plan to integrate confluent's schema

[jira] [Commented] (BEAM-3788) Implement a Kafka IO for Python SDK

[ https://issues.apache.org/jira/browse/BEAM-3788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16956261#comment-16956261 ] Chamikara Madhusanka Jayalath commented on BEAM-3788: - I believe unbounded SDF support

[jira] [Commented] (BEAM-3788) Implement a Kafka IO for Python SDK

[ https://issues.apache.org/jira/browse/BEAM-3788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16955943#comment-16955943 ] Chethan UK commented on BEAM-3788: -- [~chamikara] Any Docs? Wanted to use Kafka in Dataflow pipelines...

[jira] [Commented] (BEAM-3788) Implement a Kafka IO for Python SDK

[ https://issues.apache.org/jira/browse/BEAM-3788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16860419#comment-16860419 ] Chamikara Jayalath commented on BEAM-3788: -- This is blocked till we have a streaming source

[jira] [Commented] (BEAM-3788) Implement a Kafka IO for Python SDK

[ https://issues.apache.org/jira/browse/BEAM-3788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16859396#comment-16859396 ] Willem Pienaar commented on BEAM-3788: -- [~chamikara]:Is there anything still blocking this from being

[jira] [Commented] (BEAM-3788) Implement a Kafka IO for Python SDK

[ https://issues.apache.org/jira/browse/BEAM-3788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1683#comment-1683 ] Chad Dombrova commented on BEAM-3788: - Hi, any updates on this?   > Implement a Kafka IO for Python