怎么判断kafka的topic是否存在

可以通过Kafka的AdminClient API来判断指定的topic是否存在，具体实现可以参考以下Java代码：

import org.apache.kafka.clients.admin.AdminClient;
import org.apache.kafka.clients.admin.AdminClientConfig;
import org.apache.kafka.clients.admin.ListTopicsResult;
import org.apache.kafka.clients.admin.TopicListing;
import java.util.Properties;
import java.util.concurrent.ExecutionException;

public class KafkaTopicExistenceChecker {

    public static void main(String[] args) throws ExecutionException, InterruptedException {
        String bootstrapServers = "localhost:9092"; // Kafka集群的地址
        String topicName = "test-topic"; // 待检查的Topic名称

        Properties props = new Properties();
        props.put(AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapServers);

        AdminClient adminClient = AdminClient.create(props);
        ListTopicsResult topicsList = adminClient.listTopics();
        boolean topicExists = topicsList.names().get().stream().anyMatch(existingTopicName -> existingTopicName.equals(topicName));
        if (topicExists) {
            System.out.println("Topic " + topicName + " exists.");
        } else {
            System.out.println("Topic " + topicName + " does not exist.");
        }

        adminClient.close();
    }
}

其中，`AdminClient`是Kafka提供的用于管理Kafka集群的API客户端，`listTopics()`方法返回一个`ListTopicsResult`对象，可以调用其`names()`方法获取Kafka集群中所有Topic的名称列表。最后，利用Java 8中的Lambda表达式遍历Topic名称列表，检查待检查的Topic是否存在。