是否可以从Apache Beam / Google Cloud Dataflow的Azure EventHub主题中进行消费？

Question

问题

我们希望使用Google Cloud中的数据流管道从Azure中的EventHub主题中消费。

问题

是否知道KafkaIO是否允许直接在Apache Beam / Google Cloud数据流作业中使用EventHubs？ （请参见this post）

也欢迎将EventHub数据放入发布/订阅的替代方法（例如，从Azure流分析发布到发布/订阅）

谢谢！

Answer 1

Azure Event Hubs与Kafka协议二进制兼容，因此任何Kafka客户端或管道都应能够使用Event Hubs主题中的事件。