Kafka消费主题需按【业务域.功能模块.环境】结构拼接，环境字段严格为dev/test/prod；Laravel可通过配置组合或基类常量实现，Hyperf支持注解+生成器方式，且环境必须取自DEPLOY_ENV而非SAPI。
在PHP框架中拼接Kafka消费主题，需结合实际业务标识、环境隔离与分区策略生成唯一且可路由的主题名，避免不同服务或环境间消息混用。
确定主题命名结构
主题名必须包含业务域、功能模块、环境三要素，顺序固定为 【业务域.功能模块.环境】，例如 billing.payment.dev。漏掉环境字段会导致测试消息流入生产消费者。
业务域取英文缩写（如 user、order、log），禁止使用下划线或中文拼音首字母混搭；功能模块名需与消费者类名保持语义一致；环境字段严格限定为 dev / test / prod，不可用 staging 或 local 替代。
在Laravel中动态拼接主题名
方法一：在配置文件中定义基础片段 → 在 Consumer 类构造时组合
立即学习“PHP免费学习笔记（深入）”；
编辑 config/kafka.php，添加：'topic_prefix' => env('KAFKA_TOPIC_PREFIX', 'app'), 'env_suffix' => env('APP_ENV', 'dev')；
在 app/Kafka/Consumers/PaymentConsumer.php 的 __construct() 中写：$this->topic = config('kafka.topic_prefix') . '.payment.' . config('kafka.env_suffix');
方法二：直接从容器解析环境 + 读取类常量
定义抽象基类 BaseConsumer，声明 protected const MODULE = 'refund'；在构造函数里调用 $appEnv = app()->environment()，然后拼成 【config('kafka.domain', 'sys'). '.' . static::MODULE . '.' . $appEnv】；
注意：static::MODULE 必须由子类显式定义，不能依赖反射获取类名，否则 payment_refund_consumer 会错误解析出 refund_consumer。
在Hyperf中通过注解注入主题
第一步：创建主题生成器类 TopicBuilder
第二步：在 @Consumer 注解中引用该生成器，写法为 @Consumer(topic="TopicBuilder::buildRefundTopic", groupId="refund-group")；
第三步：TopicBuilder::buildRefundTopic() 方法内硬编码业务域前缀，读取 Hyperf\Context\ApplicationContext::get()->get(StdoutLoggerInterface::class)->info() 不参与拼接，只用于调试；
第四步：返回字符串格式为 sprintf('%s.refund.%s', $domain, $env)，其中 $env 来自 $_ENV['DEPLOY_ENV'] 而非 PHP_SAPI 判断——【SAPI 是 cli 不能代表部署环境】。
