我和Apache·比姆一起工作。我的任务是从kafka主题中提取数据并在dataflow中进行处理。数据流支持kafkaio吗?Kafka约支持哪些跑步者?
bwitn5fc1#
对。kafkaio由dataflow和其他主要的beam runner支持。我们有针对java和python sdk的kafka转换。注意,python版本是跨语言转换,dataflow需要runner v2。
1条答案
按热度按时间bwitn5fc1#
对。kafkaio由dataflow和其他主要的beam runner支持。
我们有针对java和python sdk的kafka转换。
注意,python版本是跨语言转换,dataflow需要runner v2。