花了很多小时后,我发现我也应该在下面使用它
KafkaConsumerConfig。
通过以下更改,代码可以正常工作。
props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092");

花了很多小时后,我发现我也应该在下面使用它
KafkaConsumerConfig。
通过以下更改,代码可以正常工作。
props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092");