概述
第二课 配置Topic
- 第二课 配置Topic
第二课 配置Topic
在Spring Boot中，会自动注册一个KafkaAdmin的bean。这个bean能够自动将topic注册到kafka中。
所以，我们只需要定义一些NewTopic，并将其注册为Spring的bean，那么它们就能够自动注册到kafka中。就像下面这样。
@Bean
public NewTopic topic1() {
return TopicBuilder.name("thing1")
.partitions(10)
.replicas(3)
.compact()
.build();
}
TopicBuilder可以辅助我们创建NewTopic。
如果创建tokic失败是很严重的事情，例如想要停止程序之类的，那么就应该配置：
spring:
kafka:
admin:
fail-fast: true
在创建KafkaAdmin这个bean时，这个属性就会设置给属性fatalIfBrokerNotAvailable。
那么在Topic创建的时候，如果kafka的broker不可访问的话，程序就会结束，并抛出错误：Could not configure topics。
最后
以上就是和谐镜子为你收集整理的第二课 配置Topic第二课 配置Topic的全部内容，希望文章能够帮你解决第二课 配置Topic第二课 配置Topic所遇到的程序开发问题。
如果觉得靠谱客网站的内容还不错，欢迎将靠谱客网站推荐给程序员好友。
本图文内容来源于网友提供，作为学习参考使用，或来自网络收集整理，版权属于原作者所有。
发表评论 取消回复