上一篇 <<<Kafka中的专业术语都有哪些
下一篇 >>>Kafka集群如何实现相互感知
Apache Kafka是分布式发布-订阅消息传递系统,Kafka是一种快速、可扩展的、设计内在就是分布式的,分区的和可复制的提交日志服务。
JMS规范包含:点对点和发布订阅规范,Kafka并没有遵循JMS规范,它只提供了发布和订阅通讯方式。
kafka中文官网:http://kafka.apachecn.org/quickstart.html
Kafka的设计原理

a、生产者和消费者都配置集群信息,生产者发送消息时通过轮询等策略发布到不同的broker上,消费者监听集群的所有broker,会自动读取对应的消息信息。
b、集群的搭建是依赖于zookeeper的,之间如何相互感知参考后续问题。
节点创建的时候,会创建到任意一个服务器里,不一定是当前服务器
Kafka消费组的特性
a、一个消费者只能属于一个消费组
b、同一个主题会往订阅他的所有消费组发送消息,但消费组内只能有一个消费者实现消费
c、kafka分组默认消费者与Broker是一对一的
为什么要实现分组
a.可以实现扩展,发布订阅、点对点,类似于rabbitmq中的点对点、工作、发布订阅模式,可以模拟支持死信队列
b.多系统之间存在
推荐阅读:
<<<消息中间件的核心思想
<<<消息中间件常见问题汇总
<<<基于Netty简单手写消息中间件思路
<<<消息队列常用名词与中间件对比
<<<Rabbitmq基础知识
<<<Rabbitmq示例之点对点简单队列
<<<Rabbitmq示例之工作(公平)队列
<<<Rabbitmq示例之发布订阅模式
<<<Rabbitmq示例之路由模式Routing
<<<Rabbitmq示例之通配符模式Topics
<<<Rabbitmq示例之RPC模式
<<<Rabbitmq队列模式总结
<<<Rabbitmq如何保证消息不丢失
<<<Springboot利用AmqpTemplate整合Rabbitmq
<<<Rabbitmq如何保证幂等性
<<<Rabbitmq的重试策略
<<<Rabbitmq通过死信队列实现过期监听
<<<Rabbitmq解决分布式事务思路
<<<Rabbitmq解决分布式事务demo
<<<Rabbitmq环境安装
<<<Kafka中的专业术语都有哪些
<<<Kafka集群如何实现相互感知
<<<Kafka如何实现分区及指定分区消费
<<<Kafka如何保证消息顺序消费
<<<Kafka如何保证高吞吐量
<<<Kafka集群环境搭建
<<<RocketMQ架构原理
<<<RocketMQ、RabbitMQ和Kafka的对比
<<<SpringBoot整合RocketMQ示例
<<<RocketMQ保证顺序消费demo
<<<RocketMQ如何动态扩容和缩容
<<<RocketMQ如何解决分布式事务
<<<RocketMQ单机版本安装
<<<RocketMQ集群环境程序启用相关知识点
<<<RocketMQ单机做主备实操
<<<RocketMQ所有配置说明
