kafka-consumer-api

0熱

1答えて

R rkafka.readを呼び出すときに "INFO：メッセージを読んだ後に消費者を閉じてください"を取り除く方法

私は現在kafka - rkafkaのRのパッケージを使用しています。私がカフカから読むたびに、私は「情報：メッセージを読んだ後に消費者を閉じることを忘れないでください」というメッセージを得る。どうすればそれを避けることができますか？ >library(rkafka) >consumer<-rkafka.createConsumer("1.2.3.4:2181","Real-time-data"

r apache-kafka kafka-consumer-api 2017-10-04

---

1熱

1答えて

Spring JDBC - カフカのコンシューマに対するリトライブル例外

私はカフカのトピックからメッセージを読むためにSpring Kafkaコンシューマを使用しています。私はこれらをOracle DBに残しています。 DB接続エラーが発生したときはいつでも、再試行したいと思います。Spring JDBCを使用してOracle DBに接続しています.JDBC接続の問題のみを再試行する必要がある場合に追加する必要がある例外クラスのリストは何ですか？ private st

java spring spring-jdbc kafka-consumer-api spring-kafka 2017-10-04

---

1熱

1答えて

Kafka Consumer - リカバリメソッドでリスナーが受け取ったパラメータを取得します。

私はスプリングカフカコンシューマを構築しています。私は再試行の仕組みを設定しました。再試行が終わったら、失敗したメッセージをデッドレターのトピックにプッシュしたいと思います。 を聞く方法は、以下の回復方法の一環として public void listen(@Payload Map<String, Object> conciseMap, @Header(KafkaHeaders.RECE

spring spring-boot kafka-consumer-api kafka-producer-api spring-kafka 2017-10-05

---

1熱

1答えて

カフカストリームのフィルタリング：ブローカーまたは消費者側？

私はカフカストリームを探しています。非常に低い選択性（数千に1つ）のフィルタを使用してストリームをフィルタリングしたい。 （私は実際にはそれらを捨てるために、消費者にGBの多くを転送したくない https://kafka.apache.org/0100/javadoc/org/apache/kafka/streams/kstream/KStream.html#filter(org.apache.k

apache-kafka kafka-consumer-api apache-kafka-streams 2017-10-06

---

0熱

2答えて

カフカで同じ話題の消費者数に制限はありますか？

同じ グループ内の同じトピックについて、Kafkaは同時接続（ Consumer.createJavaConsumerConnectorで作成）に制限がありますか？ 私のシナリオでは、私は私がハイレベルの消費者の多くを作成する必要がそう、異なるプロセス（ない スレッド）からトピックを消費する必要があります。

java apache-kafka kafka-consumer-api 2017-10-07

---

0熱

1答えて

Apache kafka - コンシューマー遅延オプション

小さな遅延で特定のトピックのカフカでコンシューマーを始めたい。具体的には、メッセージを作成してから特定の時間が経過した後、消費者がトピックからメッセージを消費し始めるようにします。誰もがそれを可能にするためにカフカに任意のプロパティまたはオプションがあると言うことができます。前もって感謝します。

apache-kafka kafka-consumer-api 2017-10-10

---

3熱

1答えて

Kafka Streams：レコードのタイムスタンプ（0.11.0）を変更する方法は？

私はKafkaにメッセージを送るためにFluentD（最後の安定版バージョン12）を使用しています。しかし、FluentDは古いKafkaProducerを使用しているので、レコードのタイムスタンプは常に-1に設定されます。 したがって、WallclockTimestampExtractorを使用して、メッセージがカフカに到着した時点のレコードのタイムスタンプを設定する必要があります。 私が本当に

java kafka-consumer-api kafka-producer-api apache-kafka-streams 2017-10-12

---

1熱

2答えて

StreamSetsデータコレクタがKafkaから間違った時刻を読み取る

StreamSetsデータコレクタが誤った日時値を読み取ったようです。 私はConfluentから簡単なトピックを読んでみました：Landoop Kafkaトピックでミリ秒単位で日付時刻をチェックすると正確な日時が表示されますが、StreamSetのKafka Consumer 0.10.0.0で読むと、そして20分小さい。私の実際のタイムゾーンはGMT + 03：00です。 私のSDCの設定には

timezone kafka-consumer-api confluent streamsets 2017-10-16

---

0熱

1答えて

Kafka Consumer：onPartitionsRevokedコールバックとonPartitionsAssignedコールバックを1回のpoll（）コールの中で実行できますか？

私はkafka consumer api 0.10.2.1を使用しています。 KafkaConsumerは、パーティションの割り当ておよび取り消しのためにコールバックを提供する： public void onPartitionsRevoked(Collection<TopicPartition> partitions); public void onPartitionsAssigned(Coll

java apache-kafka kafka-consumer-api 2017-10-18

---