kafkakafka 设置消费group为最新offset import org.apache.kafka.clients.consumer.ConsumerConfig import org.apache.kafka.tools.OffsetManager import java.{uti... 1年前 (2020-12-29) 2℃
kafkakafka单独设置数据过期时间 kafka 单独设置某个topic的数据过期时间 kafka 默认存放7天的临时数据，如果遇到磁盘空间小，存放数据量大，可以设置缩短这个时间。 全局设置 修改 server.properties log.retention.hours=72 log.cleanup... 1年前 (2020-12-29) 3℃