一、消息监听器

1.1、消息监听器接口

消息监听器顾名思义用来接收消息，它是使用消息监听容器的必须条件。目前有8个消息监听器：

  • 使用自动提交或容器管理的提交方法之一，处理从 Kafka 消费者 poll() 操作接收到的各个 ConsumerRecord 实例。
    public interface MessageListener<K, V> { void onMessage(ConsumerRecord<K