spring-kafka

0熱

2答えて

kafkaプロデューサ/コンシューマの再起動後にコンシューマがメッセージを受信しない

1人のプロデューサ& 1つのコンシューマ& 1つのパーティション。コンシューマ/プロデューサはどちらもスプリングブートアプリケーションです。コンシューマーアプリはローカルマシン上で実行され、プロデューサーはkafka &飼い飼い子機と共にリモートマシン上で実行されます。 開発中に、プロデューサアプリケーションをいくつか変更して再デプロイしました。しかしその後、私の消費者はメッセージを受け取っていま

java apache-kafka spring-cloud-stream spring-kafka 2017-09-12

---

1熱

1答えて

java.lang.NoSuchMethodError：org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter。（Ljava/lang/reflect/Method;）V

私はjava.lang.NoSuchMethodError: org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.<init>(Ljava/lang/reflect/Method;)VにSpring-Cloud-DependenciesバージョンのCamden SR5を取得しています。 誰も私がこの問

spring-cloud-stream spring-kafka 2017-09-15

---

1熱

1答えて

spring @Beanを使用してカフカトピックを作成していますか？

spring beanを使ってカフカトピックを作成することは可能ですか？ RabbitMQのQueueとTopicExchangesは、プログラムでこれらのように作成できます。 @Bean Queue queue(){ return new Queue("name"); } ドキュメンテーションがうまくいきませんでした。

spring-boot apache-kafka spring-kafka 2017-09-15

---

2熱

1答えて

spring-kafkaを使用してリスナー用に複数のブートストラップサーバーを渡す方法

同じトピックを持つ複数のkafkaサーバーから読み込む必要があるリスナーが、すべて1人の飼い主の下に構成されています。それらの複数のサーバーからどのように読み込むのですか。これで助けてくれますか？ カフカサーバーの代わりに、私は飼い葉桶に向けることができますか？

apache-kafka kafka-consumer-api spring-kafka 2017-09-19

---

1熱

1答えて

春カフカ・リスナー|私は、ユーザーIDが削除されますトピック名「ユーザー」を持っている

同じメッセージを読んで、私は機能私は同じトピックを指している2人のリスナーを持って読みたい 1. process user leave data 2. process user salary data 以下でこのトピックやプロセスから読みたいです同じユーザーIDを使用して処理を並行して開始します。 processPayRollはすべての時間を呼び出さなっている - @KafkaListene

spring spring-boot apache-kafka spring-kafka 2017-09-19

---

1熱

1答えて

Spring Kafka -Consumerが呼び出さないメソッドを呼び出す

私はリスナークラスにConsumerSeekAwareを実装しています。しかし、オーバーライドされたメソッドregisterSeekCallback、onPartitionsAssigned、onIdleContainerは呼び出されません。私の消費者設定ファイルとコンシューマファイルは以下の通りです。 間違いを特定できませんでした。 を使用したスプリングカフカ：1.1.6バージョン。 消費者：

spring-kafka 2017-09-20

---

0熱

1答えて

o.apache.kafka.clients.NetworkClient - ブートストラップブローカー<hostname>：9092が切断されました

私はカフカのトピックからのメッセージをSpring Kafka consumerを使用して消費しようとしています。以下のエラーが表示されます。私のローカルマシンに設定されたカフカのトピックからのメッセージを消費するときにうまく動作します - [org.springframework.kafka.KafkaListenerEndpointContainer＃0-0-C-1] WARN o.apach

java spring spring-boot spring-kafka 2017-09-20

---

0熱

1答えて

手動コミットのためのSpring KafkaのAcknowledgement.acknowledge（）メソッドの使用方法

私はSpring Kafkaを初めて使用しています。ここで述べたように私のコンシューマーコードでAcknowledgement.acknowledge（）メソッドを使用することはできません。私の春のブートアプリケーションです。手動コミットプロセスを使用していない場合、コードが正常に動作しています。しかし私が Acknowledgement.acknowledge（）を使用すると、手動コミットのため

java spring-boot kafka-consumer-api spring-kafka 2017-09-20

---

0熱

1答えて

Spring-kafka listener concurenncy

私はspring-kafka libを使用してKafka消費者を実装しました。 私は2つのパーティションを持つKafkaトピックを持っていますが、コンテナインスタンスがspring-kafka documentationに従って単一パーティションから消費する必要があるため、並行性レベルを2に設定したConcurrentKafkaListenerContainerFactoryを使用します。 Kaf

java spring multithreading spring-kafka 2017-09-21

---

0熱

1答えて

spring kafka、MessageDeliveryException：チャンネルへのメッセージの送信に失敗しました

ソース、プロセス、シンクに関する問題に苦しんでいます。私は2つのプロジェクト、アプリケーションを持っています。 1つはソース用で、もう1つはプロセスとシンク用です。 私は各コンポーネントを共有して、何が起こったか把握してください。 @EnableBinding(MultiProducerChannel.class) public class RealTimeDataSource{ @Auto

spring-cloud-stream spring-kafka 2017-09-22

---