spring-kafka

1熱

1答えて

@KafkaListenerと@StreamListenerと@ServiceActivatorの違いは？

私はKafkaをSpring BootとAvroスキーマと併用したいと思っています。 しかし、私はこれらの3人のリスナーの違いは何ですか？ リスナーを作成するには、次の3つの方法があります。 - @KafkaListener、@StreamListenerまたは@ServiceActivatorのメソッドに注釈を付けます。彼らのすべてが入ってくるイベントを聞いているようですが、私はこれらのソリュー

spring-cloud-stream spring-kafka 2017-11-28

---

0熱

1答えて

MaplStreamとSpring統合Kafkaプロデューサの問題

mapr-streamをバネ統合で使用していて、maprstreamのトピックにメッセージを送信するためにパブリッシャを作成しようとしています。私はhereと記されている以下のJarバージョン互換性マトリックスを使用しています。 春統合カフカ - 2.0.1.RELEASE 春カフカ - 1.0.3.RELEASE カフカ、クライアント - 0.9.0.0-MAPR-1607春に述べたように 私は

spring spring-integration spring-kafka mapr-streams 2017-12-01

---

0熱

1答えて

kafkaクラスターがダウンした後に@KafkaListenerが無限ループに入ります

私は3ノードのkafkaクラスターを持っています。私はdebezium（kafka-mysqlコネクター）を使用しています。 トピックコンシューマとして@KafkaListenerというメソッドを記述します。 その後、手動でkafkaクラスタをシャットダウンします（kill -15）。 その後、リスナーは突然無限ループに陥ります。 topコマンド jstack と消費者のログ（無限） これはバグで

java spring apache-kafka spring-kafka 2017-12-02

---

0熱

1答えて

SpringクラウドストリームMessageChannel send（）は常にtrueを返します

私はSpringクラウドストリームを使用していますが、Kafkaサーバーがなくてもメッセージを保存してトピックに公開したい場合は、MessageChannel send Kafka/Zookeeperサーバーが停止していても真です。 誰かが助けることができますか？ application.ymlコンテンツと UPDATE： spring: cloud: stream:

spring spring-boot spring-cloud-stream spring-kafka 2017-12-06

---

0熱

1答えて

registerSeekCallback（）を使用してSpring Kafkaでシーク操作を行う

org.springframework.kafka.listener.ConcurrentMessageListenerContainerには、トピックのN個のパーティションをリスンするN MessageListenerがあります。場合によっては、最後にコミットされたオフセットとは異なるオフセットでアプリケーションを開始する必要があります。 私はリスナーをConsumerSeekAwareとし、r

apache-kafka kafka-consumer-api spring-kafka 2017-12-06

---

1熱

1答えて

春の統合カフカのClassNotFoundException：春-統合カフカライブラリと春のブートアプリケーションを実行している間KafkaHeaderMapper

が、私は次のエラーを取得しています： Caused by: java.lang.ClassNotFoundException: org.springframework.kafka.support.KafkaHeaderMapper 例外が本体に最初の行でスローされます以下の方法： @ServiceActivator(inputChannel = "producerChannel") public

java spring apache-kafka spring-integration spring-kafka 2017-12-07

---

0熱

1答えて

春のカフカ消費者が1つのパーティションからメッセージを受信しなくなったときを検出するにはどうすればよいですか？

私は、3つのパーティションからのメッセージを取得する3つのスプリングカフカコンシューマ（同じグループ）を持っています。私は、これらの消費者のうちの1人が1つのパーティションから読み込みを停止すると検出したい（他の2人の消費者は他の2つのパーティションから読み込みを続ける）。これはこれまでに2回起こっており、検出された場合、再バランスを引き起こすすべての消費者を再起動して修正するのは簡単です。この問

apache-kafka spring-kafka 2017-12-09

---

0熱

1答えて

春のクラウドストリームkafkaバインダーで「bindingService」という名前のBeanを作成中にエラーが発生しました

カフカのトピックのイベントを聴くためのアプリケーションを作成しましたが、参照用にGitHub（https://github.com/meta-magic/Kafka-Example）で共有されています。 アプリケーションを使用して開発されています 春ブーツ1.5.9.RELEASE 春クラウドEdgware.RELEASE アプリケーションが起動に失敗している のpom.xml <project

spring-cloud spring-cloud-stream spring-kafka 2017-12-12

---

0熱

1答えて

バグkafkaバッチリスナー - バッチで手動でオフセットをコミットする

カフカのトピックからメッセージのリストを読み込み、RESTサービスに送信するバネカフカバッチリスナーを実装しています。 RESTサービスが停止した場合のオフセット管理について理解したいと思います。バッチのオフセットはコミットしないでください。メッセージは次のポーリングのために処理する必要があります。私は春のカフカのドキュメントを読んだが、リスナーエラーハンドラと現在のコンテナエラーハンドラのシーク

spring spring-boot spring-kafka 2017-12-13

---