clj-kafka

0熱

1答えて

カフカキューが空であることを確認してください

今私はカフカキューに数百のメッセージを書き込む機能を持っています。しかし、これらのメッセージがすべて消費された場合、私は追加の機能も実行する必要があります。それが空になったときに通知を受けるためにリスナーをカフカのキューに置く方法はありますか？

clojure apache-kafka clj-kafka 2016-04-05

---

2熱

1答えて

clj-kafka - 消費者が空

私はusginライブラリclj-kafkaを試しています。 ここに私のコード (use [clj-kafka.producer] [clj-kafka.zk] [clj-kafka.consumer.zk] [clj-kafka.core])) (brokers {"zookeeper.connect" "localhost:2181"}) (def p

clojure apache-kafka clj-kafka 2016-04-22

---

0熱

1答えて

clj-kafkaを使用して保持時間を把握していますか？

clj-kafkaを使用して、実行時にカフカのトピック保持時間を検出する方法はありますか？

clojure apache-kafka clj-kafka 2017-01-10

---