4

kafkaを使ったsparkストリーミングで最新のメッセージだけ読みたいのですが、過去のデータも取得してしまいます

Spark の KafkaUtil で auto.offset.reset を設定する方法

JavaPairReceiverInputDStream<String, String> messages =
            KafkaUtils.createStream(jssc, args[0], args[1], topicMap);

現在のメッセージのみをフェッチするように conf を設定する方法。例を挙げてください。

前もってありがとう、別のスレッドもあります

しかし、十分ではありません。pls は私を助けてくれます。前もって感謝します。

4

1 に答える 1