依据Partition和Consumer的Rebalance策略，找到Kafka.Client Rebalance代码块，还原本地环境，跟踪调试，发现自定义Consumer Group 的Consumer并没有分配到PartionID,如下图、依据Partition和Consumer的Rebalance策略，找到Kafka.Client
阅读背景：
.net Kafka.Client多个Consumer Group对Topic消费不能完全覆盖研究总结（二）
来源：互联网
分享到：
