2017-01-16 101 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 –