diff --git a/kafka-01/kafka-01-consumer/src/main/resources/application.yml b/kafka-01/kafka-01-consumer/src/main/resources/application.yml index 0290342..d4ae8c3 100644 --- a/kafka-01/kafka-01-consumer/src/main/resources/application.yml +++ b/kafka-01/kafka-01-consumer/src/main/resources/application.yml @@ -1,8 +1,8 @@ spring: kafka: - # bootstrap-servers: 10.10.10.200:9092 - bootstrap-servers: 10.10.10.200:9192,10.10.10.200:9292,10.10.10.200:9392 + bootstrap-servers: 10.10.10.200:9092 + #bootstrap-servers: 10.10.10.200:9192,10.10.10.200:9292,10.10.10.200:9392 consumer: # 自动提交的时间间隔 在spring boot 2.X 版本是值的类型为Duration 需要符合特定的格式,如1S,1M,2H,5D diff --git a/kafka-01/kafka-01-producer/src/test/java/cn/skcks/study/springcloud/kafka/tests/KafkaConfigTest.java b/kafka-01/kafka-01-producer/src/test/java/cn/skcks/study/springcloud/kafka/tests/KafkaConfigTest.java index 1735078..9c8b8fc 100644 --- a/kafka-01/kafka-01-producer/src/test/java/cn/skcks/study/springcloud/kafka/tests/KafkaConfigTest.java +++ b/kafka-01/kafka-01-producer/src/test/java/cn/skcks/study/springcloud/kafka/tests/KafkaConfigTest.java @@ -93,7 +93,7 @@ public class KafkaConfigTest { } return a.isInternal() ? -1 : 1; }).forEach(topic -> { - log.info("topic isInternal=>{}, uuid=>{}, name=>{}", topic.isInternal(), topic.topicId(), topic.name()); + log.info("topic isInternal => {}, uuid => {}, name => {}", topic.isInternal(), topic.topicId(), topic.name()); }); } }