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

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

import scala.collection.JavaConversions._