application.yml中正确的Springboot -Kafka参数是什么？
application.yml中正确的Springboot -Kafka参数是什么？
提问于 2021-08-05 12:33:55
尝试使用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);
}提前谢谢。
回答 2
Stack Overflow用户
回答已采纳
发布于 2021-08-05 14:36:55
如果没有前缀，这些只是您需要通过@Value连接到自己的常规用户属性
您可以找到所有spring.kafka属性in the Spring documentation
话虽如此，您列出的两个属性并未在其中列出，但这并不妨碍您创建自己的ConsumerFactory，可以在其中添加这些属性
Stack Overflow用户
发布于 2021-08-05 15:26:08
如果你使用的是org.springframework.kafka:spring-kafka，请看下面的图片，它没有提到的属性。
关于您的另一个问题，对于并发的kafka侦听器，我创建了一个ConcurrentKafkaListenerContainerFactory的@Bean，并将其作为参数传递给@KafkaListener注释中的参数containerFactory。
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/68666706
复制相关文章
相似问题
腾讯云开发者
