Kafka之拦截器Interceptor

克虏伯

发布于 2020-07-14 10:02:46

78300

代码可运行

文章被收录于专栏：软件开发-青出于蓝软件开发-青出于蓝

运行总次数：0

代码可运行

Kafka client版本0.10

ProducerInterceptor

List-1

public interface ProducerInterceptor<K, V> extends Configurable {
     
    public ProducerRecord<K, V> onSend(ProducerRecord<K, V> record);

    public void onAcknowledgement(RecordMetadata metadata, Exception exception);

    public void close();
}

onSend方法，在消息发送到Broker之前会调用
onAcknowledgement，是Broker端返回确认消息后调用

ConsumerInterceptor

List-2

public interface ConsumerInterceptor<K, V> extends Configurable {
    
    public ConsumerRecords<K, V> onConsume(ConsumerRecords<K, V> records);

    public void onCommit(Map<TopicPartition, OffsetAndMetadata> offsets);

    public void close();
}