spring-kafka

0熱

1答えて

私はSCS 1.3.0.RELEASEを使用しています。私はプロデューサーとコンシューマーアプリケーションを持っています。コンシューマアプリケーションを起動することなく、少数のメッセージを送信するプロデューサアプリケーションを使用しました。その後、コンシューマアプリケーションを起動しましたが、メッセージは消費されませんでした。両方がアップしているときは、コンシューマアプリケーションが正しく処理され

3熱

1答えて

kafkalistenerでオフセットを設定する方法

私はkafkaサーバーからデータを消費しようとしていますが、私は@Kafkalistener注釈を使用しています。問題は、アプリケーションを再起動するたびにすべてのメッセージが表示されてしまうことです。アプリケーションで最後に消費されたオフセットを保存して、次のメッセージを消費するにはどうすればよいですか？

1熱

1答えて

春カフカコンシューマー/リスナーグループ

@KafkaListenerで指定する対消費者 spring.kafka.consumer.group-id でグループを指定することの違いは何ですか？ @KafkaListener(topic="test", group = "test-grp")

0熱

1答えて

スプリングカフカ：カフカリスナー - 消費者.seek号

DBに処理された後、各レコードを承認するSpring KafkaListenerを使用しています。 DBへの書き込みに問題がある場合、私たちはレコードを承認しないので、オフセットはコンシューマーにコミットされません。これはうまく動作します。次に、次のポーリングで失敗したメッセージを取得して再試行します。 errorhandlerをリスナーに追加し、ConsumerAwareListenerErro

2熱

1答えて

bean kafkaListenerContainerを起動できませんでした：java.lang.IllegalArgumentException

私はthisをspring integrationを使用してファイルを読み込むための例として使用していますが、それはうまく動作しますが、kafkaプロデューサにファイルを送信しようとすると動作しません。インターネットでこの問題を調べようとしましたが、ヘルプが見つかりませんでした。ここは私のコードです：ファイル：MessageProcessingIntegrationFlow.java： @Be

0熱

1答えて

例外のSpring Kafka Stopコンテナ

私はConcurrentMessageListenerContainerを使って自動コミットをfalseに設定して、トピックからのメッセージを消費してデータベースに書き込みます。データベースがダウンしている場合は、コンテナが投票で現在のレコードを処理するのをやめ、次の処理を行わないようにする必要がありますpoll()。 DataSourceHealthIndicatorを実装し、データベースの状態

0熱

1答えて

Spring Kafka： `onMessage`を使用して通知するのではなく、新しいメッセージをポーリングする

私はカフカのメッセージを消費するためにSpringベースのプロジェクトで自然な選択と思われたので、プロジェクトでSpring Kafkaを使用しています。メッセージを消費するには、MessageListenerインターフェイスを使用できます。 Spring Kafkaは内部的に、新しいメッセージごとに私のonMessageメソッドを呼び出すように気を付けます。私の設定では、新しいメッセージを明示

0熱

1答えて

埋め込みカフカ以降のテストで遅れてコンシューマにメッセージを送信する

私はkafka-spring-testバージョン2.0.1.RELEASE（最新）のEmbeddedKafkaを使用しています。私は、1つのテストだけを実行しているときに正しく動作する非常に簡単なテストを行っています。しかし、私はそれらを次々と実行しているので、2番目のテストが失敗します。 - 消費者doestはメッセージを受け取りません。 public class KafkaControll

0熱

1答えて

バインダーを初期化することができません：BinderException：10秒後に春のクラウドストリームアプリのスターターが失敗します

私はtwitterソース用の春の雲のストリームアプリを実行しています。ドッキング・イメージが正常に開始し、10秒後にorg.apache.kafka.common.errors.TeamoutExceptionをスローすると失敗します。60000ミリ秒後にメタデータを更新できませんでした。 kafka_2.10-0.10.1.0 また、私はカフカ-10互換のドッキングウィンドウの画像を使用してい