Necesito leer un tema específico de Kafka, hacer un procesamiento MUY breve en el mensaje y pasarlo a un clúster de Kafka diferente .

Actualmente, estoy usando un consumidor que también es productor en el otro servidor kafka.

Sin embargo, la API de transmisión supuestamente ofrece una opción de alto rendimiento más liviana.

Así que las preguntas son:

  • Suponiendo que mi código de procesamiento no requiera mucha potencia, ¿es mejor la API de transmisión?
  • ¿La APi de transmisión admite la escritura en un clúster de Kafka diferente?
  • ¿Cuáles son las desventajas de la API de transmisión en comparación con la API del consumidor?
7
sternr 16 ene. 2017 a las 11:38

1 respuesta

La mejor respuesta

Desafortunadamente, KafkaStreams actualmente no admite la escritura en un clúster de Kafka diferente.

3
Matthias J. Sax 16 ene. 2017 a las 23:27
1
Como solución alternativa, puede usar #process() y usar una instancia adicional de KafkaProducer allí. Cf. stackoverflow.com/questions/41796207/…
 – 
Matthias J. Sax
27 feb. 2017 a las 21:28