consumer

0熱

1答えて

私のRabbitMQサーバは完全に動作しています。ポートとIPについては以下を確認してください。 C:\Users\parmarc>netstat -ano | find "5672" TCP 0.0.0.0:5672 0.0.0.0:0 LISTENING 2704 TCP 0.0.0.0:15672 0.0.0.0:0 LISTENING 2704

4熱

1答えて

メッセージを生成するときにトピックが見つかりません：UNKNOWN_TOPIC_OR_PARTITION

2ノードのカフカクラスタ（EC2インスタンス）があり、各ノードは別々のブローカーとして使用されています。リーダーインスタンスで次のコマンドを使用してプロデューサを実行すると、 kafka-console-producer.sh --broker-list localhost:9092 --topic test 次のエラーが発生します。 kaka-topics.shでトピックをリスト test

0熱

3答えて

消費者外のリストを変更するには

私は学校の問題に取り組んでいます。このメソッドの多くは既に実装されており、あまりにも多くの変更を加えることはできません。実際には私はのスポットに変更することしかできません。私が取り組んでいるメソッドのコードですが、いくつかの単語はオランダ語で書かれています。ファイルの行を読み込み、テキストからアドレスを作成し（street + "+ number +" "+ place）として保存されます）

-1熱

1答えて

ActiveMQ非永続配信モードの制限？

私は私の生産者はすでに非常に高速であるとしてメッセージを消費/処理する必要はありませ毎秒リースでの処理が必要2Kメッセージを非常に高速な消費者を持ってするには、次の要件を必要な場所私はActiveMQのを使用していますサーバーのクラッシュやその他の障害が発生した場合に再度通知します。私はプロセス全体を再度トリガーすることができます。非常に通常のコンフィギュレーション・サーバを実行する必要が

0熱

1答えて

メッセージの量がretention.bytesのmaxsizeに達すると、kafkaはメッセージを削除し、オフセットはゼロにリセットされますか？

私はkafkaを初めて使用しています。カフカを使用すると、retention.bytesを設定できます。メッセージの量が1GBに達すると、kafkaはメッセージを削除します。私はオフセットがゼロにリセットされることを尋ねますか？ 2番目に、消費者はauto.offset.resetを最大に設定し、kafkaがメッセージを削除した後、消費者はどのオフセットを開始しますか？

4熱

3答えて

カフカブートストラップサーバーとkafka-console-consumerの動物園員

私は3人のブローカー&飼い猫を持つカフカノードを1つテストしてみようとしています。私はコンソールツールを使ってテストしたいと思っています。 kafka-console-consumer --zookeeper localhost:2181 --topic testTopic --from-beginning そして、私はプロデューサーでメッセージを入力し、予想通り、消費者にそれらを見ることがで

0熱

1答えて

Pact JVM Junitコンシューマコンパイルエラー

JVm-Junitライブラリを使用して、Pact用コンシューマサイドコードを作成しています。ただし、次の行にあります。 MockProviderConfig config = MockProviderConfig.createDefault（）; エラーが発生しました。「MockProviderConfigタイプに対してcreateDefault（）が未定義ではありません」私は何ができるのですか

0熱

1答えて

Apache Kafka - コンシューマーファンダメンタルズ

私は、私の会社のブローカーに接続するためにApache Kafkaを使用する必要があります。問題はこれまで私がこの技術を使ったことがないことです。これは私が少し明確にする必要があるものです。実際に、〜/ bin/kafka-console-consumer.sh --zookeeper localhost：2181 --topic testGaultier --from-コマンドで動作するZoo

1熱

1答えて

java.lang.NoClassDefFoundErrorが：IO /ネッティー/ utilに/同時/ RejectedExecutionHandlers

私はパックJVMコンシューマを使用してテストを書いていますし、私はテストを実行したときに、以下のエラーを取得しています： - コード： - @Test public void createUser() throws Exception { Map<String, String> responseHeaders = new HashMap<>(); responseHeader

0熱

1答えて

KAFKA Javaコンシューマが動作しない

Javaコンシューマ向けの作業をローカルホストで実行できません。コンソールコンシューマは正常に動作します。以下は私の消費者コードです。パブリッククラスTestConsumer { 公共の静的な無効メイン（文字列[]引数）が例外をスロー{ //Kafka consumer configuration settings String topicName = "test";// args[