consumer

1熱

1答えて

私は消費者を築いており、カフカの話題からのすべてのメッセージが適切に読み込まれて処理されるようにしたい。自動コミット機能は魅力的ですが、私はオフセットを完全に制御したいと思っています。つまり、処理がうまくいけばオフセットをコミットしたいだけです。しかし、私は自動コミットをfalseにすることの欠点についてはわかりません。自動コミットのPROとCONは何ですか？それはより遅く行うつもりですか？同じ

1熱

2答えて

特定のカフカトピックに接続している（new-）コンシューマーを見る方法

私は新しいコンシューマー（pythonコンシューマー）のリストを持っています。私は、このコマンドを使用してグループを取得することができます bin/kafka-consumer-groups.sh --new-consumer --bootstrap-server localhost:9092 --list 私は話題彼らは私もすべてのグループ（好ましくはすべての消費者を得ることができますどのよ

0熱

1答えて

カフカの消費者が受け取ったデータを絞り込む方法はありますか？

私はdocsを読んでいて、max.poll.interval.msというプロパティを見つけましたが、私が必要とする設定ではないようです。基本的には、n秒ごとにレコードをポーリングするように消費者に指示するには、min.poll.interval.msのようなものが必要です。 max.poll.recordsと組み合わせて、私のサービスが適切な負荷量を処理していることを保証することができます。

1熱

1答えて

パイプコンシューマー/プロデューサー：コンシューマー/プロデューサーと言えば、フォーク後の父/息子

まず、悪い英語が使用されている場合はごめんなさい。私の注意書きでは、子プロセスは通常プロデューサですが、その理由を理解できません。 fork（）コールの後で、消費者とプロデューサは誰ですか？問題は、子プロセスがプロデューサである場合、彼は父が行う前に終了することになります。つまり、子プロセスはゾンビプロセスになります。それは問題ではありません

1熱

1答えて

Kafka `__consumer_offsets`トピックに大きな負荷がかかることはありますか？

私はカフカクラスター（Kafka 0.11.0.0）で簡単に観察できます。 jmx情報によれば、__consumer_offsetsのトピックには常に他のすべてのトピックのすべてのメッセージの合計よりも10倍多くのメッセージがロードされます。私はこのトピックにコンソールコンシューマーを接続しました。私は同様の値を測定できます。何故その理由が考えられますか？カフカブローカーが何をしているのかを

2熱

1答えて

PACT .NET消費者テスト：フレキシブルな長さの配列

柔軟な長さの配列を返すAPIをテストするためにpactNetを使用しています。私が "myApi/items /"を呼び出すと、消費者がの正確なサイズを知らない項目のリストを返すはずです。だから、答えは次のようになります。 [ { "id": "1", "description": "foo" }, { "id":

0熱

1答えて

Activemqを使うと、複数の排他的な消費者をどのようにしてキューに入れることができますか？

ご存知のように、単一の消費者だけがキューから順番に消費することを許可するExclusive Consumerを使用することはできますが、私には4人の消費者がいます。それらは残念ですが、私たちは1人の消費者だけのために独占消費者を使用することができます。注：これは、単一の「独占」を可能に私はあなたが4人の消費者がキューから読みたい場合は、あなたが原因の名前として独占消費者を使用したくない利用のト

1熱

2答えて

カフカ：トピックを複数の独立した消費者グループが消費できるか

私はこの情報をオンラインで簡単に見つけることができないのは間違いですが、できませんでした。ですから、私の質問はカフカの話題が1つあることです。 2つの消費者グループが互いに独立してこのトピックのメッセージを消費したいと思っています。だから私が望むのは、両方の消費者グループが、互いに独立したすべてのメッセージを見て、消費することができるということです。もう少し明確にするために、私はある消費者グルー

0熱

1答えて

Pact JVM Java初心者初心者/初心者/チュートリアルプロジェクトですか？

JARインポートを除いて、コンパクトなjvmコンシューマーJava（コンシューマーまたはプロバイダー）junitプロジェクトがありますか？たとえば、ここに示すステップを実行すると、https://github.com/DiUS/pact-jvm/tree/master/pact-jvm-consumer-junitと "基本ConsumerPactTestを使用する"というエラーが発生しますが、

1熱

1答えて

TornadoのRequestHandlerで__init__で呼び出された非同期のコンシューマは、静的に呼び出されるのとは異なる動作をするのはなぜですか？

私は各ハンドラのためのユニークなキューを持つTornadoを使用して非同期サーバを作ろうとしています。ジョブは、エンドポイントが呼び出されるとキューに入れられます。キューからジョブを非同期に '消費する'コンシューマ関数があります。しかし、消費者の行動は、それをself.consumer()とかAsyncHandler.consumer()と呼ぶかによって異なる傾向があります。私の最初の推測は、イ