Kafka之拦截器Interceptor

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

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