spring-kafka

0熱

2答えて

スプリングクラウドストリームカフカプロデューサーメッセージ

スプリングブラスストリームカフカプロデューサーをスプリングブーツでセットアップしたいですか？ プロデューサーが働いていると私はカフカブローカーからのメッセージを消費することができますが、メッセージには、次のようないくつかのヘッダ情報が含まれています。 contentType "text/plain"originalContentType "application/json;charset=UTF-

java spring apache-kafka spring-cloud-stream spring-kafka 2017-08-22

---

0熱

1答えて

これはkafkastreamをブロックする正しい方法ですか？

私の仕事は、リモートのデータベースからデータを取得し、それらをkafkaストリームに組み込むことです（濃縮）。私が今やりたいことは、定期的にリモートDBをローカルメモリにポーリングすることです。このポーリング操作が行われると、カフカストリームを一時的に停止する必要があると思います。 @Autowired private KafkaStreams streams; @Scheduled(cro

apache-kafka apache-kafka-streams apache-kafka-connect spring-kafka 2017-08-22

---

0熱

1答えて

複数のインスタンスを持つ春のエンタープライズWebアプリケーションの場合、カフカからオフセット値を取得して保存する方法は何ですか？

私は、カフカシステムから読み込んでイベントをトリガする必要があるエンタープライズWebアプリケーションを開発しています。誰もがオフセットを取得する方法を示唆し、オフセットを保存する理想的な方法（理想的な方法は、アプリケーションの複数のインスタンスによるアクセスを処理できるはずです）？ 注： - 私はspring-kafkaを使用しており、さらに詳しい提案をしています。 ありがとうございます。

spring kafka-consumer-api spring-kafka 2017-08-24

---

0熱

2答えて

Kafka処理できないメッセージを消費する - 後で壊れたメッセージを再処理する方法？

私たちはSpring Kafkaを使用してKafka Consumerを実装しています。単一のメッセージの処理が失敗した場合、私が正しく理解しているように、のオプションがあり いくつかの再試行が使用して処理しています気にしてばかりACK ないでくださいRetryTemplate も、これが機能しない場合RecoveryCallback 私はあなたのベストプラクティスがそれにどういうことをしているの

apache-kafka kafka-consumer-api spring-kafka 2017-08-25

---

1熱

2答えて

カフカリスナーセッションのタイムアウト時のロールバックトランザクション

私はトピックからのメッセージを消費するためにspring-kafkaバージョン1.1.3を使用しています。自動コミットは、コンシューマ設定でtrueとmax.poll.records〜10に設定されています。 session.timeout.msは、サーバーと10秒間ネゴシエートされます。 私はメッセージを受け取ると、その一部をデータベースに保存します。グループがすでにリバランスとにパーティション

spring apache-kafka spring-kafka 2017-09-01

---

0熱

1答えて

カフカ消費者がカスタムグループに参加しません。

Iカフカコンシューマーファクトリーをスプリングカフカの文書に従ってセットアップします。 しかし、groupIdは使用されていないようです。たぶん私も全部が間違っているので、私はあなたが私が何を経験したかを伝えたいと思っていました。 これは動作するようには思えない私の設定です： @Bean ConsumerFactory<String, KafkaEvent> kafkaEventConsumer

java spring apache-kafka spring-kafka 2017-09-04

---

2熱

2答えて

複数のトピックのSpring Kafka単一プロデューサ

JSONオブジェクトを複数のトピックに書き込むために1つのプロデューサを使用したいと思います。 次のコードは、私がしたいことをしていますが、KafkaTemplateにメッセージを送信する必要があることを伝えるのに、setDefaultTopic()メソッドを使用するのは間違っています。 よりsend(String topic, ? payload)メソッドを使用すると機能しません。 マイプロデュ

java spring spring-kafka 2017-09-06

---

1熱

1答えて

org.apache.kafka.clients.NetworkClientブートストラップブローカブートストラップサーバ - IP：9092 disconnected

私のローカルシステム上でapache kafkaを実行していて、絶対にうまく動作しています。しかし、煙のテスト中、私のアプリケーションはカフカクラスターに接続できません。それは際限なく次のエラーを投げ続ける： propsMap.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, "<host1>:9092,<host2>:9092); propsMap.pu

apache-kafka apache-zookeeper kafka-consumer-api spring-kafka 2017-09-07

---

0熱

2答えて

Spring Kafkaパーティション用の複数のコンシューマ

私たちは、スプリングカフカを使用してメッセージを消費しています。メッセージを受け取るために各パーティションの受信機を作成しました。今では、単一のパーティションからコンシューマメッセージに複数のレシーバが必要な要件があります。 パーティション0があるとします。現在、このパーティションからメッセージを受信するレシーバ（Receiver 1）は1つだけです。 これで、同じパーティション（パーティション0

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

---