我希望使用 kafka 仅读取 spark 流中的最新消息,但它也会获取过去的数据
如何在 KafkaUtil 中为 spark 设置 auto.offset.reset
JavaPairReceiverInputDStream<String, String> messages =
KafkaUtils.createStream(jssc, args[0], args[1], topicMap);
如何将 conf 设置为仅获取当前消息。请举一些例子。
提前谢谢,还有另一个线程
但还不够,请帮帮我。提前致谢。