application.yml 中正确的 Springboot -Kafka 参数是什么？

Question

尝试使用 Springboot-Kafka。几个疑问。 application.yml:

中的 Kafka 调优参数是否有效

fetch-max-bytes: 52428800

知道这在 Kakfa 上是否有效属性吗？我在我的 springboot 项目的 application.yml 中使用它来控制我的消费者轮询行为。其次，在这个块中有多个线程由 KafkaListener:

内部启动

@KafkaListener(id = "instance1", groupId = "${spring.kafka.consumer.group-id}", topics = "${spring.kafka.consumer.topic}")
    public void consume(String message) {
        System.out.println("Hellolistener ..."+message);
        log.info("container1 Message recieved from Kafka topic :{} ", message);
    }

提前致谢。

Answer 1

没有前缀，这些只是您需要通过 @Value

自己连接的常规用户属性

您可以找到所有 spring.kafka 个属性 in the Spring documentation

也就是说，您列出的两个属性并未在此处列出，但这并不妨碍您创建自己的 ConsumerFactory 以添加这些属性

Answer 2

如果您使用的是org.springframework.kafka:spring-kafka，请看下面的图片，它没有提到的属性。

关于您的另一个问题，对于并发的 kafka 侦听器，我创建了 ConcurrentKafkaListenerContainerFactory 的 @Bean 并将其作为参数传递给 @KafkaListener 注释中的参数 containerFactory。

application.yml 中正确的 Springboot -Kafka 参数是什么？

What are the correct Springboot -Kafka parameters in application.yml?

java

apache-kafka

spring-kafka