文章目录概述使用场景实战配置文件配置类自定义ConSumerInterceptor使用概述ConsumerInterceptor是Kafka中的一个重要组件，它允许开发人员在Kafka消费者端拦截和修改消息的处理过程。ConsumerInterceptor可以用于实现各种功能，从消息监控到数据转换和错误处理，为开发人员提供了更大的灵活性和可定制性。ConsumerInterceptor的主要作用是在消息被消费之前和之后对其进行拦截和处理。它可以用于以下几个方面：监控：通过ConsumerInterceptor，可以在消息被消费之前和之后记录和监控消息的元数据，例如消息的偏移量、主题、分区等信息

文章目录Pre思路示例配置文件自定义拦截器使用测试小结PreApacheKafka-ConsumerInterceptor实战(1)用代码的方式实现了ConsumerInterceptor,接下来我们用配置的方式来实现一下。思路如何找配置类KafkaProperties有些属性是很明显的有的，其他没有的一般都在Map里那map的keyvalue从哪里找呢？找原生的配置KafkaConsumer的都在ConsumerConfig找到publicstaticfinalStringINTERCEPTOR_CLASSES_CONFIG="interceptor.classes";OK，继续示例配置文件