【摘要】现有方案 之前kafka消费端采用的是standalone模式，使用的是单分片。消费端指定分片0。使用了zookeeper进行选主。只在主节点进行消费。这个选主的过程要几分钟才能选出来。之后为了保证消息不丢失，已经执行完的kafkaOffset会保存到数据库。每次在重启时会拉取数据库里的kafkaO 阅读全文