我应该在哪里获取创建 Kafka 生产者时缺少的属性?

问题描述 投票:0回答:1

你能解释一下我应该在下面的代码中哪里得到丢失的属性吗?
(smth 应该在 lsat 行中)

KafkaProperties prop = new KafkaProperties();
KafkaProperties.Producer producer = prop.getProducer();
producer.setBootstrapServers(List.of(kafkaIP));
producer.setValueSerializer(JsonSerializer.class);
return producer.buildProperties(<smth should be here>);
apache-kafka spring-kafka kafka-producer-api
1个回答
0
投票

您应该在启动配置文件中执行此操作,而不是编写代码,除非您使用 KafkaTemplate 和 Factory bean。

参见https://docs.spring.io/spring-boot/docs/current/reference/html/messaging.html#messaging.kafka

关于可以配置的内容,请参阅 Kafka 文档本身。

© www.soinside.com 2019 - 2024. All rights reserved.