在部署kafka时出现的一个问题

明明在本地部署没有什么问题,一到其他环境就出现异常,我们来看看异常长什么样子

org.apache.kafka.common.errors.UnsupportedVersionException: Creating topics with default partitions/replication factor are only supported in CreateTopicRequest version 4+. The following topics need values for partitions and replicas: [DELETE_ROUTE]

其实也好理解,就是没法创建那个topic咯
如果你使用的是spring cloud stream 的话,只需要设置一个值

spring:
  cloud:
	stream:
      kafka:
        binder:
          replication-factor: 1

其他的设置我省略了,加上这个之后就没有啥问题了,可以去部署看看了

Logo

为开发者提供学习成长、分享交流、生态实践、资源工具等服务,帮助开发者快速成长。

更多推荐