KAFKA value foreach is not a member of org.apache.kafka.clients.consumer.ConsumerRecords

在代码中加入如下内容(Scala支持与Java的隐式转换),

import scala.collection.JavaConversions._  

 

Related Posts

发表回复

您的邮箱地址不会被公开。 必填项已用 * 标注