Kafka Producer攔截器

Kafka中的攔截器(Interceptor)是0.10.x.x版本引入的一個功能,一共有兩種:Kafka Producer端的攔截器和Kafka Consumer端的攔截器。本篇主要講述的是Kafka Producer端的攔截器,它主要用來對消息進行攔截或者修改,也能夠用於Producer的Callback回調以前進行相應的預處理。apache 使用Kafka Producer端的攔截器很是簡單
相關文章
相關標籤/搜索