This commit is contained in:
Shikong 2023-04-28 09:39:10 +08:00
parent 3d3ae65494
commit d7da5c5078
2 changed files with 3 additions and 3 deletions

View File

@ -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

View File

@ -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());
});
}
}