Kafka HAの消費者設定

私の環境では1つのインスタンスが稼働していてもうまく動作していますが、複数のインスタンスを実行すると、3つのインスタンス（高可用性）アプリケーションはトピックからメッセージを消費することができます。Kafka HAの消費者設定

私はそのトピックに3つのパーティションと1つのレプリケーションファクタを持っています。

私は

./kafka-topics.sh --describe --zookeeper localhost:2181 --topic mytesttopic 

Topic:mytesttopic  PartitionCount:3  ReplicationFactor:1  Configs: 
    Topic: mytesttopic Partition: 0 Leader: 0  Replicas: 0  Isr: 0 
    Topic: mytesttopic Partition: 1 Leader: 0  Replicas: 0  Isr: 0 
    Topic: mytesttopic Partition: 2 Leader: 0  Replicas: 0  Isr: 0

を実行すると、それはmytesttopicのための構成上の私を与えます。だから私は、HAのカフカや消費者の複数のインスタンスからのメッセージを消費するためにここで欠落しているステップがわからない。

出典

2017-12-20 ppb

は、いくつかの詳細が必要です。コマンドの出力./kafka-consumer-groups.sh --bootstrap-server localhost：9092 --describe --group domain-fetching-job KafkaConsumer設定 – Abhimanyu

また、「自分のアプリケーションのインスタンスがありませんトピックからのメッセージを消費することができます "、エラーはありますか？ log4jトレースのログには何もありませんか？ –

あなたはカフカブローカーインスタンスがZookeeperに登録されており、当然異なるbroker.idであることを検証する必要があります。あなたは次の出力を取得する必要があります3パーティションに新しいトピックを作成し、あなたのdescribeコマンドを実行した後/bin/zookeeper-shell.sh localhost:2181 ls /brokers/ids

：あなたはこれを実行することによってそれを行うことができます

Topic: mytesttopic PartitionCount:3 ReplicationFactor:1 Configs: 
Topic: mytesttopic Partition: 0 Leader: 2 Replicas: 2 Isr: 2 
Topic: mytesttopic Partition: 1 Leader: 0 Replicas: 0 Isr: 0 
Topic: mytesttopic Partition: 2 Leader: 1 Replicas: 1 Isr: 1

出典

2017-12-20 21:29:11

答えて

関連する問題