特定の Kafka トピックから読み取り、メッセージに対して非常に短い処理を行い、それを別のKafka クラスターに渡す必要があります。
現在、他のkafkaサーバーのプロデューサーでもあるコンシューマーを使用しています。
ただし、ストリーミング API はおそらく、より軽量で高スループットのオプションを提供します。
質問は次のとおりです。
- 私の処理コードがそれほど馬力を必要としないと仮定すると、ストリーミング API の方が優れていますか?
- ストリーミング API は別の Kafka クラスターへの書き込みをサポートしていますか?
- コンシューマ API と比較して、ストリーミング API の短所は何ですか?