我已经在我的GKE集群中使用Strimzi Operator v0.38和Kafka Cluster 3.5.1设置了Kafka集群。我现在很困惑如何设置YAML文件来构建Kafka Connector,以便我可以在GCP Pub Sub主题中提取消息。有没有人可以帮助我?非常感谢您的帮助。
fxnxkyjh1#
您需要首先使用类型为KafkaConnect的Strimzi CRD文件部署一个Kafka连接,然后配置PubSub Sink Connector。查看使用Strimzi部署sink mongo连接器的示例,您只需使用他的configs将sink mongo连接器更改为PubSub Sink连接器
1条答案
按热度按时间fxnxkyjh1#
您需要首先使用类型为KafkaConnect的Strimzi CRD文件部署一个Kafka连接,然后配置PubSub Sink Connector。
查看使用Strimzi部署sink mongo连接器的示例,您只需使用他的configs将sink mongo连接器更改为PubSub Sink连接器