我需要从特定的Kafka主题中读取,对消息进行非常短的处理并将其传递给不同的Kafka集群.
目前,我正在使用其他kafka服务器上也是生产者的消费者.
但是,流媒体API据称可提供更轻量级的高吞吐量选项.
所以问题是:
>假设我的处理代码不需要太多马力,流媒体API是否更好?
>流式APi是否支持写入不同的Kafka群集?
>与Consumer API相比,什么是Streaming API缺点?
最佳答案 不幸的是,KafkaStreams目前不支持写入不同的Kafka集群.
我需要从特定的Kafka主题中读取,对消息进行非常短的处理并将其传递给不同的Kafka集群.
目前,我正在使用其他kafka服务器上也是生产者的消费者.
但是,流媒体API据称可提供更轻量级的高吞吐量选项.
所以问题是:
>假设我的处理代码不需要太多马力,流媒体API是否更好?
>流式APi是否支持写入不同的Kafka群集?
>与Consumer API相比,什么是Streaming API缺点?
最佳答案 不幸的是,KafkaStreams目前不支持写入不同的Kafka集群.