Kafka 流 API 与消费者 API

Kafka Stream API vs Consumer API

我需要读取特定的 Kafka 主题,对消息进行非常简短的处理并将其传递到 不同的 Kafka 集群。

目前,我正在使用一个消费者,它也是另一个 kafka 服务器上的生产者。

然而,流式处理 API 据说提供了更轻量级的高吞吐量选项。

所以问题是:

遗憾的是,KafkaStreams 目前不支持写入不同的 Kafka 集群。