Kafka系列之：深入理解过期时间TTL

一、消费者拦截器相关知识回顾

消费者拦截器使用消息过期时间TTL，通过消息的timestamp字段和ConsumerInterceptor接口的onConsumer()方法来实现消息的TTL功能。

import org.apache.kafka.clients.consumer.ConsumerInterceptor;
import org.apache.kafka.clients
1