apache-kafka - 如何使用spring kafka设置多个生产者和消费者对象？

Question

我创建了一个包含三个分区的 Kafka 主题。在 Spring-Kafka 中使用 ProducerFactory，我可以创建一个生产者实例。但是，我想创建三个生产者实例，因为我有三个分区。同样，我想要三个消费者实例。我该怎么做？请帮忙。

标签： apache-kafkaspring-kafka

Answer 1

javadocs 建议在KafkaProducer应用程序中使用单个生产者，因此 spring-kafka 就是DefaultProducerFactory这样做的。

如果您不想遵循 Kafka javadocs 的建议，您可以实现自己的ProducerFactory.

较新版本的 spring-kafka 支持为每个线程创建一个生产者。

在消费者方面，DefaultConsumerFactory将创建多个消费者。

如果您使用的是侦听器容器，只需将并发设置为 3，就会创建 3 个消费者；每个分区一个。