kafka-consumer-api

0熱

1答えて

生産者と消費者はカフカのクラスタにいくつ接続していますか？

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

apache-kafka kafka-consumer-api kafka-producer-api 2017-09-19

---

2熱

1答えて

spring-kafkaを使用してリスナー用に複数のブートストラップサーバーを渡す方法

同じトピックを持つ複数のkafkaサーバーから読み込む必要があるリスナーが、すべて1人の飼い主の下に構成されています。それらの複数のサーバーからどのように読み込むのですか。これで助けてくれますか？ カフカサーバーの代わりに、私は飼い葉桶に向けることができますか？

apache-kafka kafka-consumer-api spring-kafka 2017-09-19

---

1熱

1答えて

自動コミットが可能な状態で、手動でパーティションを割り当てる方法を教えてください。

私は、コンシューマ・グループ内の各コンシューマにパーティションを手動で割り当てようとしています。ただし、グループにコンシューマを追加すると、Kafka（または少なくともkafka-python）は、グループコーディネータにすべての割り当てを行うことを前提としています。コンシューマ・グループ（特に自動コミット）を使用することの利点をすべて維持しながら、パーティションの割り当てを手動で管理できる方法は

apache-kafka kafka-consumer-api kafka-python 2017-09-20

---

0熱

1答えて

手動コミットのためのSpring KafkaのAcknowledgement.acknowledge（）メソッドの使用方法

私はSpring Kafkaを初めて使用しています。ここで述べたように私のコンシューマーコードでAcknowledgement.acknowledge（）メソッドを使用することはできません。私の春のブートアプリケーションです。手動コミットプロセスを使用していない場合、コードが正常に動作しています。しかし私が Acknowledgement.acknowledge（）を使用すると、手動コミットのため

java spring-boot kafka-consumer-api spring-kafka 2017-09-20

---

0熱

1答えて

wurstmeister kafkaのLEADER_NOT_AVAILABLEエラー

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

apache-kafka kafka-consumer-api kafka-producer-api 2017-09-20

---

0熱

1答えて

カフカは、私は、複数のユーザーが共有<strong></strong>オブジェクトの状態を変更するためにRESTオペレーションを送ることができるアプリケーションを持っているステートフル処理に

を、メッセージを検証します。 オブジェクトが変更されると、複数のアクションが発生します（DB、監査、ログなど）。 ないすべての操作は、それが削除された後、あなたがオブジェクトを変更することはできません例えば有効です。カフカを使用して 私は、次のアーキテクチャを考えていた： 残りの操作は、カフカのトピックにキューイングされています。 同じオブジェクトへの操作は、同じパーティションしようとしています。

apache-kafka streaming kafka-consumer-api in-memory-database apache-kafka-streams 2017-09-24

---

0熱

2答えて

トピックをカフカリスナーに動的に渡す方法は？

私はJava DSLのキーを使ってトピックをカフカリスナーに動的に渡す方法を試しています。誰でもこれを行う前にこれを行うか、これを達成するための最良の方法は何かを捨てることができますか？

java apache-kafka kafka-consumer-api 2017-09-25

---

0熱

1答えて

Apache KafkaプロデューサコンシューマAPIの問題

私はカフカプロデューサとコンシューマをテストするための簡単なJava APIを作成しようとしています。 Macマシン上の別の端末でプロデューサとコンシューマを実行しているときにうまく動作します。しかし、私はこのエラーを取得し、Java APIのコードを使用してカフカサーバーに接続しようとしたとき：スレッドで 例外kafkatest2.ProducerTest.mainで「メイン」のjava.lan

apache-kafka kafka-consumer-api kafka-producer-api 2017-09-25

---

0熱

1答えて

Spring Kafkaはトピックリストからのリッスンを無効にします。

春のカフカ設定を使用して、アップストリームシステムからメッセージを受信します。 我々は別々containerfactoryを持っているとして、このコードは完全に正常に動作トピックの設定に @Bean(id="firstcontainer") protected ConcurrentMessageListenerContainer createContainerInstance(...) { /

spring-boot apache-kafka kafka-consumer-api spring-kafka 2017-09-25

---

1熱

1答えて

Spring Kafka Consumers - コンカレント・リスナーと非コンカレント・リスナー雲内

私はSpringカフカを使用してカフカ・コンシューマを作成し、クラウド・ファウンドリにデプロイしました。トピックには10個のパーティションがあります。私は、各インスタンスが1つのパーティションからメッセージを消費できるように、アプリケーションを10インスタンスに拡張する予定です。 Spring Kafkaは同時メッセージ・リスナー・コンテナもサポートしていますが、各パーティションから1つ以上のスレ

apache-kafka cloudfoundry kafka-consumer-api pivotal-cloud-foundry spring-kafka 2017-09-26

---