問題タブ [kafka-consumer-api]

質問する

For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.

3702 問題
Newest
Active
Bountied
318
Unanswered
0 投票する
0 に答える
166 参照

java - Kafka OffsetRequest の現在のバージョン

次のコードでは、kafka.api.OffsetRequest.CurrentVersion() とは何ですか? また、その意味は何ですか? 入手可能なドキュメントからはわかりません。どのようなシナリオで、別のバージョン ID が必要ですか?

0 投票する
1 に答える
1357 参照

apache-kafka - Kafka コンシューマ パスは / 文字で終わってはいけません

Web イベントを他のデータソースにストリーミングするために Apache Kafka 0.8.2.1 を使用しています。私が作成した Kafka Producer はうまく機能しており、kafka-console-consumer.sh を実行すると、トピックを通じてデータがストリーミングされているのを確認できます。ただし、Kafka Consumer にメッセージを取得させようとしても、うまくいきませんでした。何か案は？

私のコードが consumer.createMessageStreams(topicCountMap) を実行しようとすると、不適切なパスに関する次のエラーが出力されます。

これが私のKafka Consumerからのコードです。

0 投票する
4 に答える
3490 参照

multithreading - Kafka の高レベルのコンシューマー: パーティションはそれを消費する複数のスレッドを持つことができますか?

特定のパーティションからのメッセージを複数のスレッドに分割することはできますか? 1 つのパーティションと、それぞれ 100 のスレッドを持つ 100 のプロセスがあるとします。この 1 つのパーティションからのメッセージは、それらの 10000 スレッドのうちの 1 つだけに送られますか?

0 投票する
1 に答える
561 参照

apache-kafka - startOffsetTime の値が kafka.api.OffsetRequest.EarliestTime() の場合、オフセット値は何ですか?

を設定するstartOffsetTime=kafka.api.OffsetRequest.LatestTime()と、オフセットの値は利用可能な最大値になります。

設定時startOffsetTime is kafka.api.OffsetRequest.EarliestTime()のオフセット値は?

0 投票する
1 に答える
107 参照

apache-kafka - 高レベルのコンシューマはガベージ コレクションされますか?

高レベルのコンシューマーの位置は、Kafka/Zookeeper で永続化されます。これらはガベージコレクションされていますか？

0 投票する
1 に答える
1195 参照

java - Apache Kafka がプロデューサーとコンシューマーをドロップする

Apache Kafka で予期しない重大な問題が発生しています。Kafka 0.8 を使用していますが、数時間実行した後、アプリケーションがドロップし始めます。特にプロデューサー。

動作は予測不能であり、一貫して再現することはできません。

  • 私のOSはMac OSです
  • Java 7 を使用しています (Producer は Web アプリケーションです)
  • 9092 と 9093 の同じボックスで 2 つのトピックと 2 つのサーバーを実行しています

Zookeeper で次のエラーが表示されます

そして、これが9093サーバーで表示されるエラーです

私は何を間違っていますか？


12345678910