kafka-php（weiboad/kafka-php）库本身不支持动态创建 kafka 主题，其设计聚焦于生产与消费；主题需预先通过 kafka 命令行工具、adminclient（java/python）或 rest proxy 创建，否则发送消息将失败。
kafka-php（weiboad/kafka-php）库本身不支持动态创建 kafka 主题，其设计聚焦于生产与消费；主题需预先通过 kafka 命令行工具、adminclient（java/python）或 rest proxy 创建，否则发送消息将失败。
在使用 weiboad/kafka-php 进行消息生产时，一个常见误区是期望库能自动创建不存在的主题（类似某些旧版 Kafka 的 auto.create.topics.enable=true 行为）。但需明确：该 PHP 客户端完全不提供 Admin API 功能——它既无 createTopics()、listTopics()，也无 deleteTopics() 等管理接口。这是由底层协议实现决定的：当前版本（v0.3.x）仅封装了 Kafka v0.8+ 的 Produce/Fetch 协议，未集成 Kafka v0.10+ 引入的 Admin API（KIP-4）。
因此，当您执行如下代码时：
$producer->send([[
'topic' => 'test1',
'value' => 'test1....message.',
'key' => ''
]]);若 test1 主题在 Kafka 集群中尚未存在，且 Broker 配置中 auto.create.topics.enable=false（Kafka 2.0+ 默认为 false），则 send() 将抛出异常（如 Kafka\Exception\InvalidTopicException 或连接超时），消息无法投递——这正是您遇到的问题根源。
✅ 正确做法：主题必须显式创建，推荐以下三种生产级方案：
立即学习“PHP免费学习笔记（深入）”；
-
使用 Kafka 命令行工具（开发/测试首选）
在 Kafka 安装目录下执行：bin/kafka-topics.sh --bootstrap-server 127.0.0.1:9092 \ --create \ --topic test1 \ --partitions 3 \ --replication-factor 1 -
调用 Kafka REST Proxy（适合容器化/云环境）
若已部署 Confluent REST Proxy（端口 8082）：curl -X POST http://localhost:8082/v3/clusters/{cluster_id}/topics \ -H "Content-Type: application/json" \ -d '{ "topic_name": "test1", "partitions_count": 3, "replication_factor": 1 }' -
借助其他语言 Admin Client（CI/运维脚本）
使用 Python kafka-python 自动化创建（推荐集成进部署流程）：from kafka.admin import KafkaAdminClient, NewTopic admin = KafkaAdminClient(bootstrap_servers='127.0.0.1:9092') topic = NewTopic(name='test1', num_partitions=3, replication_factor=1) admin.create_topics([topic])
⚠️ 注意事项：
- 不要依赖 auto.create.topics.enable=true：该配置自 Kafka 2.0 起默认关闭，且在生产环境开启存在安全与治理风险；
- weiboad/kafka-php 已停止维护（最后更新于 2018 年），建议新项目评估更活跃的替代方案，如 php-rdkafka（虽同样暂未实现 Admin API，但支持 librdkafka v2.0+，未来更可能跟进）；
- 生产环境中，主题生命周期应由基础设施即代码（IaC）统一管理（如 Terraform + Kafka Provider），而非应用启动时动态创建。
总结：PHP 生态目前尚无成熟、稳定的 Kafka Admin API 实现。务实路径是——分离关注点：用专业工具建主题，用 kafka-php 专注高效生产消息。这不仅符合 Kafka 架构设计哲学，也保障了系统的可运维性与可靠性。
