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 –