追求……

哥们你找到问题了吗？

@半兽人，我的kafka 0.8版本，4个节点的集群，一个分区。使用高级API消费的时候吞吐量只有1000每秒，这个可能是什么原因啊？以下是关键代码：
//group 代表一个消费组
        originalProps.put("group.id", "router1");

        //zk连接超时时间
        originalProps.put("zookeeper.session.timeout.ms", "40000");
        //zk同步时间
        originalProps.put("zookeeper.sync.time.ms", "200");
        //自动提交间隔时间
        originalProps.put("auto.commit.interval.ms", "10000");
        //消息日志自动偏移量,防止宕机后数据无法读取
        originalProps.put("auto.offset.reset", "smallest");
        //序列化类
        originalProps.put("serializer.class", "kafka.serializer.StringEncoder");

太精彩了~

顶

要确认那几个topic都在正常状态，connect-*，其所在主机都处于正常。