kafkakafka 设置消费group为最新offset import org.apache.kafka.clients.consumer.ConsumerConfig import org.apache.kafka.tools.OffsetManager import java.{uti... 4年前 (2020-12-29) 7℃