kafka-producer-api

    0

    1答えて

    異なるグループのコンシューマは、同じトピックからパーティションxを読み込み、別のトピックとパーティションyに書き込むことができますか? 私は、ある消費者が他の消費者が処理するデータを破棄する消費者戦略を実装します。 データがプロデューサによって共有パーティションに保存される順序は重要ではありません。 私はちょうどこれが可能

    0

    1答えて

    最近、カフカブローカーがIOをブロックしたカーネルの問題に遭遇した(ただし、私が推測するように動物園に戻ってきたことに心を打つことができた)問題が発生しました。この結果、KafkaブローカーはISRセットにとどまっていましたが、実際には何の作業も完了できませんでした。 質問です: 1)は、ハートビートを発する前に、カフカがチェックするものを上の任意の文書があり、またはそれだけで発光ハートビートをd

    2

    1答えて

    私はプロデューサー&コンシューマーサイドでトランザクションのセマンティクスを持つ必要があるkafkaユースケースに取り組んでいます。私はkafkaトランザクションAPI 0.11を使用してトランザクションメッセージをカフカクラスターに公開することができますが、 ..プロパティファイルで、私は問題に直面してる側は...私はisolation.level=read_committedを設定している。し

    4

    2答えて

    私は、私のホスト(Windows)からゲスト(Linux)への接続に問題があり、私はKafkaをインストールしました。 ConfluentツールをインストールしたVM(VirtualBoxを使用)をセットアップしました。それは、飼育係、カフカ、およびスキーマレジストリを開始し confluent start schema-registry :このVMで、私は、コマンドを実行します。このVMの下

    0

    2答えて

    私は、いくつかのトピックからデータを取り込み、データを結合して別のトピックに配置するKafka Streamsアプリケーションを使用しています。 カフカ構成: 5 kafka brokers Kafka Topics - 15 partitions and 3 replication factor. 注:私は私のカフカブローカーが実行されている同じマシン上でカフカストリームアプリケーションを

    0

    1答えて

    私はLIBRDKAFKA Cライブラリを使用して1つのRDカフカクライアントを開発しました。 LIBRDKAFKA Cライブラリには、consumerおよびProducer Handlesの設定値を設定するためのset_config APIが公開されています。設定できる利用可能な設定は数百もあり、それぞれの値に対してset_congigが非常に面倒になりました。重要なのは、ここではコード自体にco

    0

    1答えて

    Javaクライアントで生成して使用する間に、接続数やプロデューサーとコンシューマーがKafkaクラスターに対して行った接続の種類については、誰かが分かります。 クラスタ内のトピックまたはパーティションまたはブローカに基づいた接続数はありますか?

    0

    1答えて

    下記のリンクを使用してカフカクラスタを設定しようとしています。 https://github.com/wurstmeister/kafka-docker と私はいくつかのMSGを生成しようとすると、私はこの下のエラーが発生します。 //192.168.1.162:9092 私のホスト名とポート番号を設定する [2017-09-20 17:00:53,160] WARN Error while fe