拦截器作用在生产阶段就是生产者发送一条消息给KafkaKafka收到了这样一条消息接下来需要将这个消息带入到分区器里面进行分区存入到指定的分区。但是在应用分区之前这个时候拦截器触发了拦截器拦截到的消息是在分区之前的。可以在这个时候对消息对消息进行一些处理甚至可以去修改这个消息的内容。可以看到经过拦截器的处理字母都变成了小写。这说明在生产阶段的拦截器现在是一个失效的状态。Kafka的拦截器可以作用在生产阶段也可以作用在消费阶段。生产者在生产消息的时候会将当前的时间戳作为键存到消息当中而消费者在解析消息的时候也是能够将key解析出来AdminClientAPI