提问人:Anatoly 提问时间:11/16/2023 最后编辑:OneCricketeerAnatoly 更新时间:11/17/2023 访问量:27
我应该从哪里获得用于创建 Kafka 生产者的缺失属性?
where should I get missing properties for creating the Kafka producer?
问:
您能解释一下我应该在哪里获得以下代码中缺少的属性吗?
(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>);
答:
1赞
OneCricketeer
11/17/2023
#1
此对象不应直接使用。
您应该在 Boot 配置文件中执行此操作,而不是在代码中执行此操作,除非您使用 KafkaTemplate 和 Factory bean。
查看 https://docs.spring.io/spring-boot/docs/current/reference/html/messaging.html#messaging.kafka
关于您可以配置的内容,请参阅 Kafka 文档本身。
评论