-
4 votesanswersviews
找不到主题和分区的Kafka Leader
我一直面临一个问题，Kafka集群上多个主题的一些分区在isr（同步副本）集中没有领导者甚至没有副本 . 这发生在特定经纪人ID的所有分区 - 5 . topic: topic1 partition: 2 leader: -1 replicas: 5 isr: topic: topic1 partition: 8 leader: -1 replica... -
0 votesanswersviews
Clojure - apache kafka的core.async接口
我正在使用clj-kafka，我正在尝试在REPL中创建一个 core.async 接口 . 我收到一些消息，但我的结构错了：我要么无法停止接收消息，要么必须再次启动 go 例程以接收更多消息 . 这是我的尝试： (defn consume [topic] (let [consume-chan (chan)] (with-resource [c (consumer config)] ...