你能解释一下在下面的代码中我应该在哪里得到缺失的属性吗？
(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条答案
按热度按时间bvn4nwqk1#
此对象不应直接使用。
您应该在 Boot 配置文件中执行此操作，而不是在代码中执行此操作，除非您使用KafkaTemplate和Factory bean。
请访问https://docs.spring.io/spring-boot/docs/current/reference/html/messaging.html#messaging.kafka
关于可以配置的内容，请参阅Kafka文档本身。