菜单
Use this skill when Kafka -> Flink -> Cassandra flow is stale, delayed, missing records, or behavior is inconsistent and you need structured runtime plus code-path debugging.
用 Codex 或 Claude 帮你安装 复制这段 Prompt，粘贴到 Codex、Claude 或其他助手里，让它检查 Skill 页面并帮你完成安装。
基于 SOC 职业分类
| name | taasim-streaming-debug |
| description | Use this skill when Kafka -> Flink -> Cassandra flow is stale, delayed, missing records, or behavior is inconsistent and you need structured runtime plus code-path debugging. |
Use this skill when topics are empty, Flink jobs are unhealthy, Cassandra tables are stale, or event-time logic is suspected.
docker compose config --quiet
docker compose ps
docker exec taasim-kafka /opt/kafka/bin/kafka-topics.sh --bootstrap-server localhost:9092 --list
docker exec taasim-kafka /opt/kafka/bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic raw.gps --max-messages 5 --timeout-ms 10000
docker exec taasim-kafka /opt/kafka/bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic processed.gps --max-messages 5 --timeout-ms 10000
docker exec taasim-flink-jm curl -s http://localhost:8081/jobs/overview
docker exec taasim-cassandra cqlsh -e "USE taasim; SELECT city, zone_id, event_time, taxi_id FROM vehicle_positions LIMIT 10;"
docker exec taasim-cassandra cqlsh -e "USE taasim; SELECT city, zone_id, window_start, ratio FROM demand_zones LIMIT 10;"
docker exec taasim-cassandra cqlsh -e "USE taasim; SELECT city, date_bucket, trip_id, status FROM trips LIMIT 10;"
rg -n "event_time|WatermarkStrategy|dedup|h3|zone" flink/jobs
Return:
Use this skill when API behavior, route docs, Cassandra integration, or ML fallback behavior is unclear or broken and the FastAPI contract must be corrected and documented.
Use this skill when the user asks to audit data and notebook artifacts, classify what is runtime-required vs regenerable/archive/removable, or clean repository footprint safely.
Use this skill when docs and implementation may have drift and you need to align README, documents, notebook descriptions, and actual code behavior.
Use this skill when the user asks to regenerate Casablanca simulation artifacts end-to-end (zone maps, H3 lookup, warped trajectories, trajectory index, and NYC to Casa synthetic trips) with correct git policy.