在部署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

华为开发者空间,是为全球开发者打造的专属开发空间,汇聚了华为优质开发资源及工具,致力于让每一位开发者拥有一台云主机,基于华为根生态开发、创新。

更多推荐