spring-kafka

0熱

1答えて

私はカフカのトピックとデータベースのオフセットを管理したいので、ある時点後にキューで再処理したいと思っています。これをどうやって進めることができますか？前もって感謝します。

0熱

1答えて

私のデモアプリケーションでは、メッセージをkafkaキューに戻すためにrestコントローラを作成する必要があります。私は春・カフカのリファレンスガイドを読んで、消費者の設定を実装し、作成した豆を @Configuration @EnableKafka public class ConsumerConfiguration { @Value("${kafka.bootstrap-ser

1熱

2答えて

Kafka製作者JSONシリアル化

私はKafkaとの統合にSpring Cloud Streamを使用しようとしています。書き込まれているメッセージはJava POJOであり、期待通りに動作しています（メッセージはトピックに書き込まれていて、コンシューマアプリケーションで読むことができます）。メッセージの先頭にいくつかの不明な文字が追加されていますトピックからのメッセージをシンクするためにKafka Connectを統合しようとす

0熱

1答えて

1つのパーティションでカフカトピックの同時メッセージリスナーを作成する方法

Uusing Spring Kafka org.springframework.kafka.listener.ConcurrentMessageListenerContainerは、トピック内のパーティション数とContainerPropertiesに基づいて複数のリスナーを作成します。 javadocには、「同じパーティション内のメッセージは順次処理されます」と表示されます。したがって、パーティ

1熱

1答えて

Kafka Spring統合フロー上のNULLポインタ

私はKafkaを使用してSpring統合フローを実装しようとしています。しかし、私はこのエラーにつきものです。私がデバッグすると、 "HandlerAdapter handlerMethod"がnullであることがわかりますMessagingMessageListenerAdapterです。私がここでやっていることを確かめたり、もっと必要な設定をしています。しかし、これは私が文書や他のページから

2熱

2答えて

手動コミットのためのスプリングカフカの現在のオフセットを確認する方法

私はSpring Kafkaを初めて使用しています。私のコンシューマーコードでAcknowledgement.acknowledge（）メソッドを手動コミットに使用できません。私の消費者の構成やリスナーコードに欠けていることがあれば教えてください。そうでなければ、条件に基づいて肯定応答オフセットを処理する別の方法があります。ここで私は、オフセットがコミットされていない/手動で肯定応答しない場合、

1熱

2答えて

カフカドッカー、ドッキングウィンドウ-のmaven-pluginの、春ブーツ

https://github.com/fabric8io/docker-maven-plugin 私は、次のMavenの画像を使用します。https://hub.docker.com/r/wurstmeister/kafka/ は、これは私のMavenの設定です： <plugin> <groupId>io.fabric8</groupId> <artifactId>docker

2熱

1答えて

スプリングブートJavaカフカ設定、上書きポート

私はSpring Boot + Kafkaを使用しています。、9092 今私は、ポートを変更する必要があります。この設定はかなり正常に動作し、デフォルトカフカポートにカフカのインスタンスに接続することができます @Configuration @EnableKafka public class KafkaConfig { } ：これはカフカのための私の現在、非常に単純な構成であります9

0熱

1答えて

Kafkaを使用してSpring Cloud Stream内に冪等元のプロデューサを設定するにはどうすればよいですか？

私はKafka 0.11で紹介された冪等生産者を利用したいと思います。冪等：必ず1回パーティションあたりの順セマンティクスでこの機能をオンにするとパーティションを意味していないあたり、正確ワンスセマンティクスを取得するには、このConfluent blog postによると、新たなプロパティがこれをサポートするために追加されました重複なし、データ損失なし、インオーダーセマンティクス - プ

0熱

1答えて

カフカにカスタムデータを返すことができます。プロデューサー

私はkafkaを学んでおり、私は2つのマイクロサービスに分割したいと思っています。まず、KafkaConsumerからのすべての受信メッセージをデータベースに保存し、指定されたIDでエンティティを選択します。 2番目にREST APIを提供して、エンティティを保存して取得します。カフカとの相互作用。 kafkaを使用してREST APIで格納されたIDをデータベースから受信するにはどうすればよ