kafka可插拔增强如何实现？
导弹拦截，精准防御。
背景
拦截器：在不修改应用程序业务逻辑的情况下，一组基于事件的可插拔的逻辑处理链； 类比springMVC的拦截器：
这些都是通过配置拦截器，插入到应用程序中，实现可插拔的修改业务逻辑；
kafka在0.10.0.0版本中开始引入拦截器。分为生产者拦截器和消费者拦截器，类似责任链的方式编排多个拦截器为一个大拦截器。
配置方法：配置参数
Properties props = new Properties();
List<String> interceptors = new ArrayList<>();
interceptors.add("com.yourcompany.kafkaproject.interceptors.AddTimestampInterceptor"); // 拦截器1
interceptors.add("com.yourcompany.kafkaproject.interceptors.UpdateCounterInterceptor"); // 拦截器2
props.put(ProducerConfig.INTERCEPTOR_CLASSES_CONFIG, interceptors);
……相关文章