我有一个发布/子主题和一个订阅。我在探索gcp-pubsub-kafka连接器。Kafka在两个地区有两个示例。是否可以在这两个地区使用kafka连接器,从pub/sub中的相同公共订阅中获取MSG?我想找出一种方法将msg从pub/sub移动到多个kafka示例((说循环)
ogsagwnx1#
如果您希望两个kafka示例都接收所有消息,则需要对该主题创建第二个订阅。如果希望每个kafka示例接收消息的子集,则可以使用相同的订阅设置两个cps kafka源连接器示例。
1条答案
按热度按时间ogsagwnx1#
如果您希望两个kafka示例都接收所有消息,则需要对该主题创建第二个订阅。如果希望每个kafka示例接收消息的子集,则可以使用相同的订阅设置两个cps kafka源连接器示例。