使用kafka-node V5.0.0无法删除Kafka主题，求可行解决代码

问题原因 #

kafka-node V5.0.0的API有较大更新，原代码中使用的Admin类已不再提供deleteTopics方法，且旧版回调式API被替换为Promise风格的AdminClient。

可运行的完整代码 #

const { KafkaClient, AdminClient } = require('kafka-node');

// 初始化Kafka客户端
const client = new KafkaClient({
  kafkaHost: 'localhost:9093,localhost:9094'
});

// 初始化AdminClient
const adminClient = new AdminClient(client);

async function deleteAllTopics() {
  try {
    // 获取所有主题列表
    const topicMetadata = await adminClient.listTopics();
    const allTopics = Object.keys(topicMetadata[1].metadata);
    
    // 过滤掉Kafka内部主题（可选，避免误删集群核心主题）
    const topicsToDelete = allTopics.filter(topic => !topic.startsWith('__'));
    
    if (topicsToDelete.length === 0) {
      console.log('没有可删除的主题');
      return;
    }

    console.log('准备删除的主题:', topicsToDelete);

    // 批量删除主题
    const deleteResult = await adminClient.deleteTopics(topicsToDelete);
    console.log('主题删除成功:', deleteResult);
  } catch (error) {
    console.error('删除主题失败:', error);
  } finally {
    // 关闭客户端连接
    client.close();
  }
}

// 执行删除操作
deleteAllTopics();

关键注意事项 #

• 确保Kafka集群允许删除主题：在Kafka节点的server.properties中设置delete.topic.enable=true，并重启Kafka服务。
• 保留内部主题：以__开头的是Kafka集群的核心内部主题（如__consumer_offsets），删除会导致集群异常，代码中已默认过滤。
• 依赖版本确认：运行前确保安装的是指定版本：npm install kafka-node@5.0.0

内容的提问来源于stack exchange，提问作者Saurav Thakur