1、顺序消费，正常消费 2、client 启动多个线程池，每个线程池，消费不不同操作类型的binlog 3、数据发到kafka ，按照id %分配到不同的消息队列(这一步在那做)，然后启动多个消费者，消费不同的队列，即保证了 主贴回帖id的业务顺序，又保证了消费速率
