kafka-producer-pattern - 带用户隔离的FastAPI Kafka生产者模式
从FastAPI端点向Kafka发送事件，包含强制的用户隔离
标签
更新于: 2026-03-09能力
典型输入
典型输出
该技能可以做什么
- 向Kafka发布事件
- 维护用户隔离
- 处理生产者生命周期
输入
- FastAPI端点
- Kafka引导服务器
- 用户ID
- 事件有效载荷
输出
- Kafka事件
- 日志消息
要求
- aiokafka>=0.10.0
- KAFKA_BOOTSTRAP_SERVERS环境变量
- 异步运行时环境