我需要读取特定的 Kafka 主题,对消息进行非常简短的处理并将其传递到不同的Kafka 集群。
目前,我正在使用一个消费者,它也是另一个 kafka 服务器上的生产者。
但是,流式 API 据称提供了更轻量级的高吞吐量选项。
所以问题是:
- 假设我的处理代码不需要太多马力,流式 API 会更好吗?
- 流式 API 是否支持写入不同的 Kafka 集群?
- 与 Consumer API 相比,Streaming API 的缺点是什么?
我需要读取特定的 Kafka 主题,对消息进行非常简短的处理并将其传递到不同的Kafka 集群。
目前,我正在使用一个消费者,它也是另一个 kafka 服务器上的生产者。
但是,流式 API 据称提供了更轻量级的高吞吐量选项。
所以问题是: