“Kafka剖析(一):Kafka背景及架构介绍”阅读总结

**原文连接:**http://www.infoq.com/cn/articles/kafka-analysis-part-1apache

总结

  • 不一样于 ActiveMQ 这样的消息中间件, 在 Kafka 中,只有 Topic 概念,没有 Queue 的概念
  • Topic 在物理存储上可分为多个 Partition,以提升性能和可用性
  • Kafka 经过 Consumer Group 的概念实现 Queue 的功能。在同一个 Consumer Group 的 Consumer 只能消费同一条消息一次。
  • Kafka 中并无 Consumer Group 相关的接口或类,而是经过在 ConsumerConfig 中设置相同的 group.id 来实现。相同 group.id 的 Consumer 会经过 Zookeeper 共享消息 offset,以此实现多个 Consumer 不重复读消息。https://cwiki.apache.org/confluence/display/KAFKA/Consumer+Group+Example 介绍了如何实现 Consumer Group
  • Kafka 所实现的消息模型是 Pull,相比 Push 模型更适合大并发系统,由于消费者能够更好控制消费消息的速率
相关文章
相关标签/搜索