spring-kafka

-1熱

1答えて

スプリングカフカを使用するときにプロデューサのエラーハンドラを追加するには？私は消費者のためのエラーハンドラを追加する方法を知っていますが、私はプロデューサについてはわかりません。

0熱

1答えて

カフカのトピックから一括して（一度に1つずつではなくすべての10kレコードを一括処理するために）一括してメッセージを取得したい。これをSpring Cloud Streamプロセッサで実現する方法はありますか？もしそうなら、私が参照できるスニペットや例がありますか？おかげ

2熱

1答えて

Kafkaコンシューマのjava.fang.NoSuchMethodError spring-kafka 2.1.0とSpringBoot 1.5.9を使用しています。

私は、SpringBoot（1.5.9）とSpring-kafka（2.1.0）を使用してKafka Consumerを設定しようとしています。しかし、私のアプリを起動すると、java.lang.NoSuchMethodError：org.springframework.util.Assert.state（ZLjava/util/function/Supplier;）Kafka Messaging

0熱

2答えて

log4jを使用してログのspring kafka設定を印刷する方法

log4jを使用して、すべてのspring-kafka設定をログに記録する方法はありますか？私は、アプリケーションlog4j2.ymlで以下のロガー設定を試してみましたが、すべての情報とデバッグログが表示されますが、設定は表示されませんでした。 - 名前：org.springframework.kafka 加法：偽レベル：情報/デバッグ AppenderRef： - REF：助けを事前にSOME

0熱

1答えて

kafkaバインダーで春のクラウドストリームを使用していくつかのメッセージを優先順位付けする方法

TLDR：同じトピックの他のものよりも早急にいくつかのメッセージを処理できるようにしたいと思います。詳細な説明：私はいくつかのタスクのために互いの間で話をするカフカ、バインダーと、スプリング・クラウド・ストリームに依存する多くのスプリングmicroservicesを使用して、かなり大規模なアプリケーションに取り組んでいます。スケジュールされたタスクが多数のイベントを生成することがあります。こ

0熱

1答えて

org.springframework.messaging.MessageHandlingException：欠落しているメソッドのパラメータの型のヘッダー「kafka_receivedMessageKey」[クラスjava.lang.Integerの]

マイクラスタ構成、クラスの詳細とジャーバージョンは、私が始めている質問org.apache.kafka.common.KafkaException: Failed to construct kafka consumer に記載されていますZookeeperサーバー、Kafkaサーバー、Kafka RESTサーバー次に、spring-kafka-webhook-service.warというファイル名

0熱

1答えて

Spring Cloud Stream Kafkaバインダー：「IN_TRANSACTION状態からIN_TRANSACTION状態への無効な移行が試みられました」

Spring Cloud Streams + Kafka Bindingを使用してApache Kafkaで「正確に1つの配信」コンセプトでPoCを実行しようとしています。私はApache Kafka "kafka_2.11-1.0.0"をインストールし、プロデューサに "transactionIdPrefix"を定義しました。これはSpring Kafkaでトランザクションを有効にするために必

2熱

1答えて

KSQLテーブルからデータを読み取る

おそらくこれは初心者の質問ですが、KSQLで生成されたデータを読み取るにはどうすればよいですか？ストリーム処理を行い、そのデータをKSQLテーブルに書き込むとします。今、Springアプリケーションを介してこのデータにアクセスしたいと考えています（websocket経由でライブデータをファンアウトするなど）。私の最初の推測は、スプリングカフカを使用して、根底にあるトピックに登録することでした。そ

0熱

1答えて

org.springframework.kafka.listener.ListenerExecutionFailedException：リスナーメソッドがjava.lang.NullPointerExceptionをスローしました

私のコンシューマークラスInventoryEventReceiverのリスナーメソッドで以下のエラーが発生しました。 NullPointerExceptionが表示される理由がわかりません。私はちょうど2つのInventoryEventオブジェクトを投稿しています。迅速なヘルプがあれば幸いです。私はカフカRESTプロキシを介して2つのレコードの下にPOSTしていたリスナー方法 public c