这是一个创建于 1460 天前的主题，其中的信息可能已经有所发展或是发生改变。
背景：我们系统提供的是对话数据语义离线分析的服务，可以算是个通用底层能力。这次的上游系统是一个客服系统，业务希望他们的数据接入到我们系统中。 问题：上游系统把数据放在他们 kafka 集群让我们自己去消费处理格式，处理格式也就算了。要对接上游的 kafka 集群就炸了啊。我说提供一个封装好的接口调用就可以了，我们自己放自己的 kafka 集群消化数据，还被拒绝了。 主要还和我说一般都是放在生产者的 kafka 集群的，虽然我是渠道方可能也会这么做，但我现在做的是一个平台，如果对接上游的 kafka 集群，那工作量也太多了吧，如果上游没 kafka 集群，还要多一种接入方式？回归测试的时候还要依赖这些 kafka 集群的状态？
 |
1
julyclyde 2020-11-11 11:56:14 +08:00
kafka 的消息可以被不同 consumer group 分别多次读出
所以集群肯定是归属于 producer 的 你如果想有自己的集群，可以做一下复制 |
Select Language