Kafka producer攔截器與 Stream

Kafka producer攔截器(interceptor) 1 攔截器原理 Producer攔截器(interceptor)是在Kafka 0.10版本被引入的，主要用於實現clients端的定製化控制邏輯。java 對於producer而言，interceptor使得用戶在消息發送前以及producer回調邏輯前有機會對消息作一些定製化需求，好比修改消息等。同時，producer容許用戶指定多

>>阅读原文<<