今日已办

定位昨日发现的问题

来回测试发现依然出现该问题

将 pub/sub 的库替换为原来官方基于 sarama 的实现，发现问题解决了，所以问题的根本是 kafkago 这个库本身存在问题

依据官方的实现，尝试自定义实现 pub/sub

1. sarama 与 kafka-go 的 api 差异比较大
2. 源码阅读困难

明日待办

1. 在 watemill-pub/sub 中使用 otel-sdk 上报 trace
2. 开会汇总进度和问题