Kafka两级调度实现分布式协调任务分配Golang版

主要工作分为两个步骤：通过worker获取自身的topicoffset等元数据信息。交给kafka的broker完成Leader/Follower选举workerLeader节点获取到kafka存储的partation和member信息，来进行二级分配，实现结合具体业务的负载均衡