我是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}
为了达到这个目的?
1条答案
按热度按时间ymdaylpp1#
在代理的配置中将auto.create.topics.enable设置为true。