课程
/后端开发
/Java
/Kafka流处理平台
如果我做了分布式 但是就起了一个客户端订阅 怎么办
2018-09-08
源自:Kafka流处理平台 3-2
正在回答
consumer == 客户端连接数 ?
partition作为数据存储的最小单元,如果你有多个消费者读取同一个partition。
就好比有两个糖果,糖果作为最小的不可分割的单位,但是有三个人,怎么分。这样肯定会发生数据的错乱。
如果有两个糖果,有两个人,那么就一人一个糖果。
如果有两个糖果,但是有一个人,那就好办了。一个人吃两个,也就是消费两个。
慕粉3631442
你创建了一个topic,最小的partition也应该为1,那也是等于你一个consumer.
代码有可能错误
举报
作为模块解耦和大数据处理黏合剂的不二之选Kafka,你值得拥有!
3 回答消费者如何找到想要得数据
1 回答关于partition的一个问题?
1 回答请问下,我想要控制kafka消费方在接收到消息后,不立即消费;每10秒消费一次,每次消费100条,如何实现呢
2 回答消费重复的问题
1 回答topic和partition的问题