哪些跑步者支持apachebeam中的kafkaio?

j8yoct9x  于 2021-06-04  发布在  Kafka
关注(0)|答案(1)|浏览(390)

我和Apache·比姆一起工作。我的任务是从kafka主题中提取数据并在dataflow中进行处理。数据流支持kafkaio吗?
Kafka约支持哪些跑步者?

bwitn5fc

bwitn5fc1#

对。kafkaio由dataflow和其他主要的beam runner支持。
我们有针对java和python sdk的kafka转换。
注意,python版本是跨语言转换,dataflow需要runner v2。

相关问题