Kafka学习笔记(十二)—Kafka消费者API

1、Kafka消费者简介 Kafka和其它消息系统有一个不同的设计,在consumer之上加了一层group。Consumer Group 是 Kafka 提供的可扩展且具备容错性的消费者机制。同一个group的consumer能够并行消费同一个topic的消息,可是同group的consumer,不会重复消费同一分区。java 若是消费线程大于 patition 数量,则有些线程将收不到消息;
相关文章
相关标签/搜索