【大数据技术详解】scala写kafka的consumerAPI，在while里使用迭代器中的iterator().hasNext，iterator.next()函数为什么会出现无限循环消费数据的坑？一kafaka的productor代码如下：
一kafaka的productor代码如下：import java.util.Propertiesimport org.apache.kafka.clients.producer.{KafkaProducer, ProducerRecord}object kafkaproductor { def main(args: Array[String]): Unit = { val ...
