kafka message add partition and offset - Githubissues

tx7do / kratos-transport

kratos transport layer extension

MIT License

340 stars 92 forks source link

kafka message add partition and offset #84

Closed xichengliudui closed 3 months ago

xichengliudui commented 3 months ago

之所以添加分区和偏移量原因有两个

在大量消息的场景下程序处理错误 debug 会变的困难（消息没有必要全部打印）
分区和偏移量都是 github.com/segmentio/kafka-go FetchMessage 本身返回的我们不应该丢弃掉它