kafka-consumer-api

0熱

1答えて

commitAsyncが最初の2つのオフセットをコミットできないのはなぜですか？

消費者がcomitAsyncをログの最初の2つのオフセットにすることができない奇妙な問題に直面しました。 ..私は引用誰か.Can消費者によって受信され、succesfulyコミットプロデューサーの同じ非同期送信で他のメッセージがこの問題の原因を見つけるので、それは非常に奇妙である私の次のコードと出力例 package com.panos.example; import kafka.utils

2熱

1答えて

レプリカからの消費

カフカは、トピックの各パーティションを指定した複製係数で複製します。私が知る限り、すべての書き込み要求と読み取り要求はパーティションのリーダーにルーティングされます。リーダーからではなく、フォロワーから消費する方法はありますか？カフカでの複製はフェールオーバーのみですか？

0熱

1答えて

kafka-node - 非同期関数に引数を渡します。consumer.on（）;

私のnode.jsサーバーにはkafka-nodeを使用しています - kafkaトピックに接続するためです。 APIには、コールバック関数があります。 consumer.on('message', function (message) { console.log(message); }); 到着時にメッセージを消費します。私はこのコールバック関数に引数を追加できますか？私はメッ

2熱

1答えて

ハイレベルカフカのコンシューマAPIは

Iセットアップ単一ノードカフカの仕事とそのような単純なパブリッシュ/サブスクライブパターンしようとしない：私はコードでいくつかのメッセージを生成し、私のラップトップからを： Properties props = new Properties(); props.put("bootstrap.servers", "192.168.23.152:9092"); props.put(

0熱

2答えて

トピックを使用してACLを有効にしたKafka Javaプロデューサとコンシューマ

kafka ACL設定と混同して、プロデューサとコンシューマの認可を設定します。コマンドラインを使用してメッセージを生成/消費することを示すさまざまな例があります。 JAVA APIを使用して安全なカフカのトピックに/からメッセージを生成/消費するための追加設定が必要ですか？

6熱

4答えて

Kafka Consumer - Pollの振る舞い

KafkaConsumer（> = 0.9）に関する私のニーズに対応するソリューションを実装しようとすると、深刻な問題に直面しています。私は、カフカのトピックからnというメッセージを読み取るだけの機能があるとしましょう。たとえば、getMsgs(5) - >は、トピックで次の5カフカメッセージを取得します。だから、私はこのようになりますループがあります。 for (boolean exit=

3熱

2答えて

例外：

をリバランスすることができませんでしたが、私は、トピックを作成し、私はそのトピック bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic streams-file-input bin/kafka-console-producer.sh --bro

2熱

1答えて

カフカエラー：オフセットXの要求が、我々は唯一の私はカフカのインスタンスを働いていたZ

の範囲Y内のログ・セグメントを持っていますが、今、それがどのように見えるのエラーで何千もの生成：私はデフォルトを使用してい [2016-06-24 01:33:28,092] ERROR [Replica Manager on Broker 0]: Error when processing fetch request for partition [test-topic,0] offset 45