kafka消费慢的的一次排错过程

环境:centos6.5,cdh5.7.1,kafka 0.9.0.1。html 咱们的topic有12个partitions分布在12个broker,副本数3。用的old higth level API。分别在12台机器上启动消费者,每一个都是单线程,因此就是一个consumer消费一个partition。可是呢,消费就是有积压。apache 解决:嗯,1消费者拉取数据2处理3数据流向下个目的地
相关文章
相关标签/搜索