[
https://issues.apache.org/jira/browse/BEAM-3788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16860419#comment-16860419
]
Chamikara Jayalath commented on BEAM-3788:
------------------------------------------
This is blocked till we have a streaming source framework for Python SDK for
portable runners. To this end, Splittable DoFn is currently under development.
Note that, for folks using Flink runner, native Kafka source of Flink is
currently available to Python SDK users through the cross-language transform
API.
> Implement a Kafka IO for Python SDK
> -----------------------------------
>
> Key: BEAM-3788
> URL: https://issues.apache.org/jira/browse/BEAM-3788
> Project: Beam
> Issue Type: New Feature
> Components: sdk-py-core
> Reporter: Chamikara Jayalath
> Assignee: Chamikara Jayalath
> Priority: Major
>
> This will be implemented using the Splittable DoFn framework.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
