微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

kafka总结

1.kafka集群是指多个服务器多个分区的情况

和redis集群本不一样的是redis主坏了再好后主在从变成主的情况下原恢复的主会变成备,

而kafka会在主恢复后同步备的消息读取offset点,比如如果主恢复后现在是3,备是 读到8了,那么主也会把自己的设置为8,然后重新从主 8的位置开始消费。如果主没异常,那么从只做备份,消息读取不会从从分区读取【原因:kafka是消息是磁带式消费的,如果主从都在没办法实时的同步主从的消息标识点

 】

2.kafka

group:group 是针对业务【业务即服务】来说的

比如设备服务是groupA,二维码服务是groupB,而groupA和groupB都订阅的MQ中的同一个Topic,group是MQ用来区分的

topic:topic指同一类型的需求数据

消费可以讲消息想成一个磁带,消息消费掉,磁带就少一截,但是这个磁带是在MQ管控的,所以就算消费者挂掉,等消费者恢复会从MQ之前消费的位置继续消费。需要注意的是MQ中消费这消费掉磁带变短这个只是指的标识,真正的消息还是存在的只是这个标识没有了对于消费这来说就已经被消费掉了,这条消息不会再一次被消费,MQ对它保存的消息是有失效时间的,一但消息过来失效时间,MQ会直接彻底删掉这调消息

 

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。

相关推荐