使用卡夫卡通過Observable（RxJava）

Question

我有一個生產者（使用卡夫卡），並有多個消費者。因此，我在一個主題中發佈消息，然後我的消費者接收並處理消息。

我需要從生產者那裏接收至少一個消費者的回覆（如果是第一個消費者則更好）。我正在嘗試使用RxJava來做到這一點（observables）。

有沒有可能這樣做？任何人都有一個例子？

Answer 1

ü可以按如下方式使用它：

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

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

    consumer.shutdown() 

欲瞭解更多的信息可以看出U https://github.com/cjdev/kafka-rx

Answer 2

會更好，你會首先共享您的解決方案......

由於春節云溪是，MH，流解決方案，而不是請求/響應，有沒有跟大家分享一個例子。

你可以考慮讓你的消費者也是生產者。在原始製作人有消費者閱讀答覆的話題。最後，您必須將回複數據與請求數據相關聯。

RxJava或任何其他實現細節不相關。