在kafka中如何在运行时创建随机主题?

xienkqul  于 2021-06-07  发布在  Kafka
关注(0)|答案(1)|浏览(356)

我是Kafka的新人。我试图在运行时创建一个随机的主题名。我的producer创建了一个像mq*这样的随机字符串,它将该字符串用作主题并发送给消息主题。消费者方知道这个随机主题并订阅它。但消费者无法调查记录。我在错误生产者或消费者的下面。

WARN 10816 --- [nio-8087-exec-1] org.apache.kafka.clients.NetworkClient   : Error while fetching metadata with correlation id 1 : {MQ654498631=LEADER_NOT_AVAILABLE}

为了达到这个目的?

ymdaylpp

ymdaylpp1#

在代理的配置中将auto.create.topics.enable设置为true。

相关问题