kafka采用什么模式？kafka按結(jié)構(gòu)了pull模式也就是靠靠消費者拒絕拉取。（produce將消息推回到broke，消費者拒絕拉取）pull模式：消費者愿意向broker拉取消息，合適完全不同消費

kafka采用什么模式？

kafka按結(jié)構(gòu)了pull模式也就是靠靠消費者拒絕拉取。

（produce將消息推回到broke，消費者拒絕拉取）

pull模式：消費者愿意向broker拉取消息，合適完全不同消費速率的消費者。pull缺點：當(dāng)broker沒有消息推送時，導(dǎo)致消費者不停再等待發(fā)送數(shù)據(jù)。為了以免kafaka有個參數(shù)，可以不以讓消費者阻塞。

mqtt消息如何防止丟失？

mqtt消息遵循以下步驟操作如何防止丟了:

一、絕對的保證消息投遞完成

1）Kafka

2）RabbitMQ

3）RocketMQ

二、能保證消息不會弄丟

1、生產(chǎn)者以保證消息成功了郵箱里到Broker

2、Broker可以保證消息不丟

3、消費者切實保障消息消費最終

三、只要消息成功消費

1、Kafka：關(guān)閉半自動重新提交，消費成功了之后你的郵箱ack

2、RabbitMQ：消費者回復(fù)ack確定

kafka 訂閱機制原理？

Kafka公告訂閱原理及工作機制

生產(chǎn)者（Producer）專門負責(zé)公告消息到消息中心；

消費者（Consumer）向消息中心訂閱自己感興趣的東西消息，獲得數(shù)據(jù)后通過數(shù)據(jù)處理；

消息中心（Broker）負責(zé)存儲生產(chǎn)者發(fā)布的消息和管理消費者訂閱信息，參照消費者訂閱信息，將消息推帶回去消費者。在Kafka中，消息中心本質(zhì)上就是一組服務(wù)器，也的確是Kafka集群。

Zookeeper集群為了協(xié)調(diào)和管理Broker和Consumer，實現(xiàn)方法了Broker和Consumer的解耦，并為系統(tǒng)能提供可靠性保證。

ZooKeeper集群是可以比例內(nèi)項是一個提供了分布式服務(wù)協(xié)同作戰(zhàn)能力的第三方組件，Consumer和Broker啟動時時均會向ZooKeeper接受注冊一，由ZooKeeper并且統(tǒng)一管理和協(xié)調(diào)。

ZooKeeper中會讀取一些元數(shù)據(jù)信息，諸如相對于Broker，會存儲主題隨機哪些分區(qū)（Partition），每個分區(qū)的存儲位置等；相對于Consumer，會存儲消費組（ConsumerGroup）中中有哪些Consumer，每個Consumer會共同負責(zé)消費哪些分區(qū)等。