如何从另一个Docker容器中获取所有Kafka主题？

DevOps 小满

2026-8-17

获取Docker容器内Kafka主题的替代方法

1. 直接使用Kafka自带命令行工具

如果你的应用容器具备Java环境，或者可以安装Kafka客户端工具，无需依赖主机的Docker命令，直接在容器内执行Kafka原生命令：

若容器已包含Kafka二进制包，直接运行：

kafka-topics --bootstrap-server broker:29092 --list

若没有预装，可通过包管理器安装（如Debian/Ubuntu系容器安装librdkafka-dev），或下载Kafka二进制包解压后使用其中的脚本。

2. 通过HTTP API与Kafka交互

可以部署Kafka HTTP代理服务实现HTTP方式的交互，常用的工具是Kafka REST Proxy：

启动Kafka REST Proxy容器（需与Kafka Broker处于同一Docker网络），配置其bootstrap.servers指向broker:29092
在应用容器内发送GET请求即可获取主题列表：
```
curl http://kafka-rest:8082/topics
```

返回结果为JSON格式的主题列表。

3. 使用编程语言的Kafka客户端库

通过业务代码直接调用Kafka客户端的Admin API获取主题，是最安全且贴合业务场景的方式，举例：

Python（使用kafka-python库）：

from kafka import KafkaAdminClient

admin_client = KafkaAdminClient(bootstrap_servers="broker:29092")
print(admin_client.list_topics())

Java（使用kafka-clients包）：

import org.apache.kafka.clients.admin.AdminClient;
import org.apache.kafka.clients.admin.AdminClientConfig;
import java.util.Properties;

public class ListKafkaTopics {
    public static void main(String[] args) {
        Properties props = new Properties();
        props.put(AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG, "broker:29092");
        try (AdminClient adminClient = AdminClient.create(props)) {
            adminClient.listTopics().names().get().forEach(System.out::println);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}