Kafka之拦截器Interceptor

Z时代
2024-01-10
分类：综合

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();}