kafka-consumer-api

7熱

2答えて

カフカ消費者オフセット最大値？

私はグーグルでカフカのドキュメントを読んでいましたが、コンシューマオフセットの最大値と最大値の後にオフセットラップアラウンドがあるかどうかはわかりませんでした。 オフセットはInt64値なので、最大値は0xFFFFFFFFFFFFFFFFです。 ラップアラウンドがある場合、カフカはどのようにこの状況を処理しますか？

offset apache-kafka kafka-consumer-api 2015-12-22

---

10熱

4答えて

kafkaトピックのパーティションの最新のオフセットを取得する方法は？

私はKafkaのPythonハイレベルコンシューマを使用しており、トピックの各パーティションの最新のオフセットを知りたいと考えています。しかし、私はそれを働かせることはできません。 from kafka import TopicPartition from kafka.consumer import KafkaConsumer con = KafkaConsumer(bootstrap_se

python apache-kafka kafka-consumer-api kafka-python 2016-02-16

---

9熱

4答えて

Kafkaのサポートは、応答メッセージを要求しますか？

私はKafka 9を趣味のプロジェクトとして調査し、いくつかの「Hello World」タイプの例を完成させました。 私は、一般的なリクエストレスポンスメッセージ、具体的にはカフカリクエストメッセージをレスポンスメッセージにリンクする方法に基づいて、Real World Kafkaアプリケーションについて考えなければなりません。 私は、生成されたUUIDをリクエストメッセージキーとして使用し、この

apache-kafka kafka-consumer-api kafka-producer-api mom 2016-02-21

---

8熱

5答えて

kafka consumer 0.9は下位互換性がありますか？

今後のカフカ消費者0.9.xは0.8ブローカーと互換性がありますか？ 他の言葉に触れることなく、新しい消費者の実装に切り替えることは可能ですか？引用このConsumer Client Re-design wikiページに基づいて

apache-kafka kafka-consumer-api 2015-11-19

---

8熱

1答えて

トピックメタデータを取得するときにカフカの消費者が「リーダーを見つけられませんでした」

トピックからメッセージをプッシュ/プルするためにKafkaプロデューサとコンシューマ（0.9.0）スクリプトを使用しようとすると、以下のエラーが表示されます。 プロデューサーエラー [2016-01-13 02:49:40,078] ERROR Error when sending message to topic test with key: null, value: 11 bytes with

apache-kafka apache-zookeeper kafka-consumer-api kafka-producer-api 2016-01-13

---

5熱

2答えて

カフカクラスタの障害を処理する方法

カフカパブリッシュサブスクライブシステムを実装します。 最悪の場合、最悪の場合 - 特定のトピックのすべてのカフカブローカーがダウンした場合、どうなりますか？ 私はこれを試しました...メタデータフェッチのデフォルトタイムアウト後にパブリッシャーがそれを検出しました&は成功しなかった場合例外をスローします。 この場合、例外を監視し、Kafkaを修正した後でPublisherを再起動することができま

apache-kafka kafka-consumer-api 2016-03-03

---

6熱

2答えて

kafkaを新しいコンシューマapiで.9にアップグレード

カフカの実装を.9にアップグレードし、新しいコンシューマJava APIを使用してコンシューマを作成しています。私はコンシューマ向けに以下のコードを使用しています。 LINE Bは私たちが受け取ったメッセージを処理する私たちのサービスへの呼び出しです。問題は、メッセージ処理に30秒以上かかる場合、例外が発生することです。 Properties props = new Properties();

apache-kafka kafka-consumer-api 2016-03-09

---

8熱

3答えて

Kafka 0.9 KafkaConsumerでオフセットを手動でコミットするときにメッセージを再消費する方法

一連のレコードがMongoにコミットされると、手動でオフセットをコミットするユーザーを作成しています。 Mongoエラーまたはその他のエラーが発生した場合、エラー処理コレクション に後で再生するためにレコードをパースしようとします。 Mongoがダウンしている場合、Kakfaからのコミットされていないオフセットからレコードを読み取ろうとする前に、消費者が一定期間処理を停止するようにします。 以下の

apache-kafka kafka-consumer-api 2016-01-20

---

7熱

1答えて

Kafka Avroコンシューマ（デコーダー付）

Kafka Consumer with Avroをそれぞれのスキーマでデータに実行しようとすると、「AvroRuntimeException：不正なデータ：長さが負の値：-40」というエラーが返されます。私は他の人が同様の問題を抱えているのを見る。coverting byte array to json、Avro write and read、およびKafka Avro Binary *coder

java apache-kafka avro kafka-consumer-api apache-nifi 2016-03-15

---

2熱

2答えて

カフカの消費者は、私はカフカサーバからのメッセージ（トピック）を消費するKafkaConsumerを使用してい

を追加しました。.. それは消費者のコードを開始する前に作成したトピックのため正常に動作します... しかし、問題は動的に作成されたトピック（コンシューマーコードが開始された後のことを言いたい）がAPIに動的トピックの作成をサポートすると言われている場合は機能しません。 使用カフカ版：0.9.0.1ここで https://kafka.apache.org/090/javadoc/index.htm

java apache-kafka kafka-consumer-api 2016-03-22

---