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