kafka比rabbitmq吞吐量更高,但是在消息确认这块,rabbitmq支持性更好.
kafka集群的一个服务器节点可以存多个topic(主题)和partition(分片),replication(备份文件)数量不能大于节点数量
检查节点状态
zkServer.sh status
kafka查找数据算法是利用偏移量,使用二分法+hash寻址
一条消息同一个消费者组只能接收一次,如果两个消费者不在同一个小组,那么这两个消费者都能接收到同一条消息
kafuka 不会删除历史数据,但是可以无限扩容,适合用于大数据分析
setrequireack() 设置生产者发送消息后kafka是否发送回执.0不需要,1需要,2不单需要,而且要从节点同步成功-生产端
setisasyn() 设置回执是同步还是异步true,false-生产端
setGroupId() 设置消费者分组-消费端,消费端没有ack机制
kafka高可用
1.主从备份,从节点主动去主节点取数据