kafkaを使ったsparkストリーミングで最新のメッセージだけ読みたいのですが、過去のデータも取得してしまいます
Spark の KafkaUtil で auto.offset.reset を設定する方法
JavaPairReceiverInputDStream<String, String> messages =
KafkaUtils.createStream(jssc, args[0], args[1], topicMap);
現在のメッセージのみをフェッチするように conf を設定する方法。例を挙げてください。
前もってありがとう、別のスレッドもあります
しかし、十分ではありません。pls は私を助けてくれます。前もって感謝します。