kafka如何知道消息成功被消费 kafka采用什么模式？
kafka采用什么模式？
kafka按结构了pull模式也就是靠靠消费者拒绝拉取。
（produce将消息推回到broke，消费者拒绝拉取）
pull模式：消费者愿意向broker拉取消息，合适完全不同消费速率的消费者。pull缺点：当broker没有消息推送时，导致消费者不停再等待发送数据。为了以免kafaka有个参数，可以不以让消费者阻塞。
mqtt消息如何防止丢失？
mqtt消息遵循以下步骤操作如何防止丢了:
一、绝对的保证消息投递完成
1）Kafka
2）RabbitMQ
3）RocketMQ
二、能保证消息不会弄丢
1、生产者以保证消息成功了邮箱里到Broker
2、Broker可以保证消息不丢
3、消费者切实保障消息消费最终
三、只要消息成功消费
1、Kafka：关闭半自动重新提交，消费成功了之后你的邮箱ack
2、RabbitMQ：消费者回复ack确定
kafka 订阅机制原理？
Kafka公告订阅原理及工作机制
生产者（Producer）专门负责公告消息到消息中心；
消费者（Consumer）向消息中心订阅自己感兴趣的东西消息，获得数据后通过数据处理；
消息中心（Broker）负责存储生产者发布的消息和管理消费者订阅信息，参照消费者订阅信息，将消息推带回去消费者。在Kafka中，消息中心本质上就是一组服务器，也的确是Kafka集群。
Zookeeper集群为了协调和管理Broker和Consumer，实现方法了Broker和Consumer的解耦，并为系统能提供可靠性保证。
ZooKeeper集群是可以比例内项是一个提供了分布式服务协同作战能力的第三方组件，Consumer和Broker启动时时均会向ZooKeeper接受注册一，由ZooKeeper并且统一管理和协调。
ZooKeeper中会读取一些元数据信息，诸如相对于Broker，会存储主题随机哪些分区（Partition），每个分区的存储位置等；相对于Consumer，会存储消费组（ConsumerGroup）中中有哪些Consumer，每个Consumer会共同负责消费哪些分区等。
版权声明：本文内容由互联网用户自发贡献，本站不承担相关法律责任.如有侵权/违法内容,本站将立刻删除。
