java - Kafka通过微服务，订阅不存在的主题

Question

我有一个构建多个微服务(java spring boot)的系统，通过 grpc 和 avro 消息进行通信。它使用 Kafka 队列。我的问题是:服务正在按顺序构建，其中一个服务订阅 Kafka 主题，然后另一个服务发送消息并创建消息。我没有返回任何错误，所以它看起来可以工作，但不能。当时该主题并不存在，当它收到消息时，消费者服务也不会注意到它。如果我重新启动客户端服务，它可以加入主题并正常工作。我想解决消费者可以创建订阅的主题，或者如果没有收到任何消息则尝试重新连接。

Answer 1

是的，我也遇到过这个问题。由于这个原因和其他原因，我们提出的解决方案/最简单的解决方案是将创建主题与微服务的部署一起烘焙。 (长话短说:我们在 CI/CD 盒子上调用 kafka-topics.sh，针对适当的 Zookeeper 和代理)

如果您的微服务部署脚本知道要创建哪些主题，并确保在应用程序启动之前创建它们，那么问题就可以避免。