Kafka Verwendung durch beobachtbare (RxJava)

Question

Ich habe einen Produzenten (unter Verwendung von Kafka), und mehr als ein Verbraucher. Also veröffentliche ich eine Nachricht in einem Thema und dann erhalten meine Kunden die Nachricht und verarbeiten sie.

Ich brauche eine Antwort in dem Hersteller von zumindest einem Verbraucher zu empfangen (besser, wenn es die ersten sein). Ich versuche RxJava zu benutzen (Observables).

Ist es möglich, auf diese Weise zu tun? Jeder hat ein Beispiel?

Answer 1

u kann es wie folgt verwenden:

val consumer = new RxConsumer("zookeeper:2181", "consumer-group") 

consumer.getRecordStream("cool-topic-(x|y|z)") 
    .map(deserialize) 
    .take(42 seconds) 
    .foreach(println) 

    consumer.shutdown() 

Für weitere Informationen können u sehen https://github.com/cjdev/kafka-rx

Answer 2

Wäre besser, dass Sie vor allem Ihre Lösung teilen ...

Seit Frühling Wolke Strom ein, mh, Stream-Lösung, nicht Anforderungs-/Antwort, gibt es keine ein Beispiel mit Ihnen zu teilen .

Sie betrachten können Ihre Konsumenten als Produzenten sowie zu machen. Und im Originalhersteller muss ein Verbraucher aus dem Antwortthema lesen. Schließlich müssen Sie die Antwortdaten mit der Anfrage korrelieren.

Die RxJava oder andere Implementierungsdetails sind nicht verwandt.