-
Kafka
下载与安装（官网）：
*Zookeeper的下载：
*Kafka下载
kafka的启动：
##进入kafka的安装目录 cd /usr/local/Cellar/kafka/1.1.0/
##启动命令：./bin/kafka-server-start +(指定配置文件)
##可以在bin目录下查看kafka下有那些命令：
./bin
##创建kafka的topic
./bin/kafka-topics --create --zookeeper localhost:2181 --replication-factor 1 --partitions 3 --topic hello
结果：Create topic "hello"
##查看kafka的topic
./bin/kafka-topics --list --zookeeper localhost:2181
##生产者命令：
./bin/kafka-console-producer --broker-list localhost:9092 --topic hello
>(进入交互模式)
##消费者命令：
./bin/kafka-console-consumer --bootstrap-server localhost:9092 --topic hello --from-beginning
查看全部 -
partition
查看全部 -
划重点查看全部
-
记录一下查看全部
-
事务保证：
内部重试问题：Procedure幂等处理
多分区原子写入
查看全部 -
kafka案例测试查看全部
-
ngine lvs md5负载均衡器查看全部
-
处处见幂等查看全部
-
kafka延迟低，查看全部
-
因为kafka支持分区，支持备份，消息可以重复被消费。 高容错性，高可靠性查看全部
-
当partition很大的时候，一个partition可以很跨多个broker,但这并不是一个partition在不同的broker上被保存了多分，而是多个broker只保存了一个partition查看全部
-
同一个partition不会被多个broker同时保存。 其实也就是一个broker下只有一个partition查看全部
-
broker group 中每个broker保存一个或多个partition的数据查看全部
-
partition 每一个topic被切分成多个partition 消费者的数目要小于等于partition的数目 broker group 对broker进行分组，每个group会保存partition多份查看全部
-
Replication
当集群中有Broker挂掉的情况，系统可以主动地使Replicas提供服务
系统默认设置每一个Topic的replication系数为1（即默认没有副本，节省资源），可以在创建Topic时单独设置
特点：
Replication的基本单位是Topic的Partition;
所有的读和写都从Leader进，Followers只是做为备份（只有Leader管理读写，其他的Replication只做备份）
Follower必须能够及时复制Leader的数据
增加容错性与可拓展性
查看全部
举报