factory.setBatch Listener

在实际应用中，Kafka作为一种强大的分布式消息系统，广泛应用于实时数据处理和消息传递。本文将通过一个全面的使用案例，详细介绍如何使用Spring Boot集成Kafka，并展示其在实际场景中的应用。 在开始之前，我们需要确保已经完成以下准备工作： 安装并启动Kafka集群 创建Kafka主题（Topic）用于消息的发布与订阅 首先，我们来创建一个简单的生产者，将消息发送到Kafka主题。 @RestController public class KafkaProducerController { @Autowired private KafkaTemplate<String, String> kafkaTemplate; @PostMapping("/produce/{message}") public ResponseEntity<String> produceMessage(@PathVariable String message) { kafkaTemplate.send("my-topic", message); return...

【Spring连载】使用Spring访问 Apache Kafka（三）----接收消息 一、消息监听器Message Listeners 当你使用消息监听器容器，你必须提供一个监听器接收数据。现在有8个受支持的接口做为消息监听器。见以下代码： public interface MessageListener<K, V> { void onMessage(ConsumerRecord<K, V> data); } public interface AcknowledgingMessageListener<K, V> { void onMessage(ConsumerRecord<K, V> data, Acknowledgment acknowledgment); } public interface ConsumerAwareMessageListener<K, V> extends MessageListener<K, V> { void onMessage(ConsumerRecord<K, V> data, Consumer<?, ?> consumer); }...

1、消费者，channel，connection的关系 首先明确，这里的consumer不是一台消费者机器，而是rabbitMq的最小消费单位，一台机器可以开启多个消费者，一个消费者总是对应一个channel。 一个TCP 被多个线程共享，每个线程对应一个信道，信道在rabbit都有唯一的ID，保证了信道的私有性，对应上唯一的线程使用。 也就是rabbitMq采用一个TCP连接处理多个消费者的多线程请求，实际上就是多路复用。 2、线程模型 simple simple模式每个消费者都有其私有的线程，可以增加消费者，也会自动增加消费线程，不管消费者是不是在处理消息，可能会造成资源线程的浪费。 direct 看的出来direct的线程模型更简单，也因此压力集中在Connection线程池上，线程可以复用与多个消费者，但是如果采用这种模式,需要设置Connection线程池合适的参数。 看起来direct更好一些，那么如何选择 如何选择容器 看官网的说法 选择容器...