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