是否可以在发送消息之前检查Kafka代理和我发送消息的主题是否健康

Question

我有一个批处理应用程序，需要向两个不同集群上的两个不同Kafka主题发送消息。在发送任何消息之前，我想确保我的生产者应用所在的kafka代理连接健康。

是否可以在Spring Boot中以编程方式进行这种检查?

Answer 1

参见KafkaAdmin.describeTopics()API:

/**
* Obtain {@link TopicDescription}s for these topics.
* @param topicNames the topic names.
* @return a map of name:topicDescription.
*/
Map<String, TopicDescription> describeTopics(String... topicNames);

它连接到配置的集群，并请求主题及其分区的信息。

查看文档获取更多信息:https://docs.spring.io/spring-kafka/docs/current/reference/html/#configuring-topics