Kafka使用Strimzi操作符连接GCP PubSub

falq053o  于 5个月前  发布在  Apache
关注(0)|答案(1)|浏览(64)

我已经在我的GKE集群中使用Strimzi Operator v0.38和Kafka Cluster 3.5.1设置了Kafka集群。我现在很困惑如何设置YAML文件来构建Kafka Connector,以便我可以在GCP Pub Sub主题中提取消息。有没有人可以帮助我?非常感谢您的帮助。

fxnxkyjh

fxnxkyjh1#

您需要首先使用类型为KafkaConnect的Strimzi CRD文件部署一个Kafka连接,然后配置PubSub Sink Connector。
查看使用Strimzi部署sink mongo连接器的示例,您只需使用他的configs将sink mongo连接器更改为PubSub Sink连接器

相关问题