2017-01-16 78 views
4

我需要从特定的Kafka主题中读取,对该消息进行非常短的处理,并将其传递给不同的 Kafka集群。Kafka Stream API vs Consumer API

目前,我正在使用的消费者也是其他卡夫卡服务器上的生产者。

但是,流API应该提供更轻量级的高吞吐量选项。

所以问题是:

  • 假设我处理的代码并不需要太多的马力,是流API更好?
  • 流API是否支持写入不同的Kafka集群?
  • 与消费者API相比,Streaming API的缺点是什么?

回答

2

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

+0

作为解决方法,您可以使用'#process()'并在那里使用额外的'KafkaProducer'实例。参看http://stackoverflow.com/questions/41796207/dynamically-connecting-a-kafka-input-stream-to-multiple-output-streams –