Kafka 迁移/处理 "UNKNOWN_TOPIC_OR_PARTITION" 有必要吗？

Question

我们使用spring KafkaListener 来监听主题。一切正常。

现在我们必须迁移到另一个 Kafka Broker，在我们部署应用程序时，它不提供任何主题。

我在本地对此进行了模拟，我们的侦听器收到了无穷无尽的 UNKNOWN_TOPIC_OR_PARTITION 警告。预期的行为是什么。

Error while fetching metadata with correlation id 146 : {x-events-live=UNKNOWN_TOPIC_OR_PARTITION}

我的问题是，我们是否必须处理内存泄漏等方面的警告，或者我们是否可以等到主题可用。

@KafkaListener(
        id = "id",
        topics = ["topic"],
        groupId = "group",
        containerFactory = "myContainer",
        autoStartup = "false"
)
fun thingChnanged(@Payload thing: Thing,
                            record: ConsumerRecord<String, String>,
                            @Headers headers: MessageHeaders) {
    doSomething(thing)
}

Answer 1

没有比普通消费者 TCP 连接更多的内存泄漏。

是的，您可以等待，或者您可以将 @Bean NewTopic 添加到您的应用程序，以便应用程序本身将创建具有预期设置的主题

Kafka 迁移/处理 "UNKNOWN_TOPIC_OR_PARTITION" 有必要吗？

Kafka migration / handling "UNKNOWN_TOPIC_OR_PARTITION" necessary?

kotlin

apache-kafka

spring-kafka