4
我需要从特定的Kafka主题中读取,对该消息进行非常短的处理,并将其传递给不同的 Kafka集群。Kafka Stream API vs Consumer API
目前,我正在使用的消费者也是其他卡夫卡服务器上的生产者。
但是,流API应该提供更轻量级的高吞吐量选项。
所以问题是:
- 假设我处理的代码并不需要太多的马力,是流API更好?
- 流API是否支持写入不同的Kafka集群?
- 与消费者API相比,Streaming API的缺点是什么?
作为解决方法,您可以使用'#process()'并在那里使用额外的'KafkaProducer'实例。参看http://stackoverflow.com/questions/41796207/dynamically-connecting-a-kafka-input-stream-to-multiple-output-streams –