FinalKafka
type
status
date
slug
summary
tags
category
icon
password
kafka是基于发布/订阅模式的一个分布式消息队列系统，用java语言研发，是ASF旗下的一个开源项目；类似的消息队列服务还有rabbitmq、activemq、zeromq；kafka最主要的优势具备分布式功能，并且结合zookeeper可以实现动态扩容；kafka对消息保存是通过Topic进行分类，发送消息一方称为producer(生产者)，接收消息一方称为consumer（消费者）；一个kafka集群有多个kafka server组成，我们把每个kafka server称为broker（消息掮客）
ActiveMQ、RabbitMQ、kafka对比
示例
此示例部署在zookeeper服务上，也可以不在同一台机器上
部署Kafka集群依赖于zookeeper集群上
下载软件包
配置kafka各节点
启动kafaka
若启动失败可根据日志查找原因
验证kafka进程
测试创建topic
创建名为msgtest，partitions(分区)为3，replication(复制)为3的topic(主题)
测试获取topic
状态说明：logstashtest有三个分区分别为0、1、2，分区0的leader是3（broker.id），分区0有三个副本，并且状态都为lsr（ln-sync，表示可以参加选举成为leader）
获取所有topic
发送消息
接收消息
删除topic
上一篇
Zookeeper
下一篇
dubbo
Loading...
Docker
keepalived
sonarqube
Varnish
Openstack