4
Ich muss von einem bestimmten Kafka-Thema lesen, eine sehr kurze Verarbeitung der Nachricht und übergeben Sie es an eine andere Kafka-Cluster.Kafka Stream API vs Consumer API
Derzeit verwende ich einen Verbraucher, der auch ein Produzent auf dem anderen Kafka-Server ist.
Die Streaming-API bietet jedoch eine leichtere Option mit hohem Durchsatz.
So sind die Fragen:
- Unter der Annahme, meine Verarbeitungscode nicht viel Pferdestärke erfordert, ist die Streaming-API besser?
- Unterstützt das Streaming-APi das Schreiben in einen anderen Kafka-Cluster?
- Welche Nachteile hat Streaming API gegenüber der Consumer API?
Als Umgehung können Sie '#process()' verwenden und dort eine zusätzliche 'KafkaProducer'-Instanz verwenden. Vgl. http://stackoverflow.com/questions/41796207/dynamicly-connecting-a-kafka-input-stream-to-multiple-output-streams –