spring-kafka

1熱

1答えて

私はカフカ版0.10.2.1と私のプロジェクトのための春のブートを使用しています。私は別のマシン上で実行されている（同じグループIDを持つ）複数の消費者が消費できる話題の5つのパーティションを持っています。私が直面していますどのような問題はです：ログは、この問題は、カフカの消費者に生じたことを示しているとおり、私はこれらのカフカの警告ログを単一のメッセージ Auto offset commi

0熱

1答えて

Spring Integration - Kafkaプロデューサーエラーチャンネル

私はカフカプロデューサーを使用して、他のカフカのトピックとその動作がきれいにメッセージを公開しています。 <int-kafka:outbound-channel-adapter kafka-template="template" channel="inputToKafka" topic="foo"/> 上記のステートメントは、カフカメッセージ駆動

0熱

1答えて

1つのアプリケーションで異なる設定の2つのスプリングカフカ消費者

私はカフカの初心者です。私はSpring-Kafka POCに取り組んでいます。 KAFKAのサーバはKerberos化されています。すべての必要な設定で、Kerberos化されたKafkaサーバにアクセスできます。今度は、非Kerberized（シンプルカフカコンシューマー）カフカサーバーからのトピックを消費する必要がある別の要件があります。独自のリスナーで別のKafkaConsumerを作成す

3熱

1答えて

スプリングカフカパーティショニング

メッセージを公開する以下の2つのコードスニペットの動作の違いは何ですか？アプローチ1 Message<String> message = MessageBuilder.withPayload("testmsg") .setHeader(KafkaHeaders.MESSAGE_KEY, "key").setHeader(KafkaHeaders.TOPIC, "test").buil

1熱

1答えて

headerMode = rawのJSON MessageHeaders

私は、SleuthでトレースするSpring Cloud Stream（SCS）カフカ製作アプリを持っています。私は春・メッセージングを公開しようとしている「GenericMessage」（すなわちMessageHeaders +ペイロード）必要の両方によって消費される：（自動的にMessageHeadersに追加されたトレースを継続すべきである） SCSの消費者 MessageHeadersを

1熱

1答えて

auto-offset-reset = latestはspring-kafkaで動作しません

私は消費者に常に最新のオフセットから開始させたいユースケースがあります。このコンシューマのオフセットをコミットする必要はありません。これは、新しいコンシューマ・グループが常に新しく割り当てられたパーティションをコミットするため、spring-kafkaでは実現できません。次に、プログラムのその後の開始時に、消費者は最新のものからではなく、この記憶されたオフセットから読み出す。言い換えれば、新しい消

0熱

1答えて

スプリングカフカを使用している複数の消費者

私のアプリケーション内のカフカトピックに複数のリスナーを設定することを検討しています。以下は私のセットアップです。両方のグループで消費されるはずですが、1つのリスナーだけが消費します。私はここで何が欠けていますか？ @Bean public Map<String, Object> consumerConfigs() { Map<String, Object> props = new H

0熱

2答えて

Spring Boot Kafkaプロジェクト用のKafkaコンシューマ応答モードを設定してください

私はSpring Kafkaバージョン1.1.2.RELEASEとともにSpringブートバージョン1.5.2.RELEASEを使用しています。 application.propertiesファイルを介して、Kafka Consumerを設定するためのオプション（spring.kafka.consumer。*）が表示されます。私が見つけることができないものは、確認モードを設定する方法です。

0熱

1答えて

春の雲ストリームpartitionKeyExpression SpEL

私はspring-cloud-stream-kafkaを使用して、小さなストレステストを作成しています。このテストでは、多くのイベントが生成され、特定のカフカトピックに送信されます。トピックには6つのパーティションがあり、ユーザーIDをパーティションキーとして使用したいと考えています。しかし、ユーザーIDは常に存在するとは限りません。そのため、私はこのようなロジックをしたいと思います。存在する場

1熱

1答えて

apache kafkaの機能のような相関IDの複製

私たちは非同期通信に徹底的に使用される分散メッセージングミドルウェアとしてapache kafkaを実装しています。私はkafkaブローカーにメッセージを公開し、その特定のメッセージへの返信を聞くことができるいくつかのユースケースを持っています（ウサギmqの相関IDを使用するような場合）。私はapache kafkaプロトコルについて読んで、内部的に相関IDを使用しているようです。しかし、その