kafka的訊息確認方式有3中 ，可以在生產者的配置檔案中配置：
##0：不保證訊息的到達確認，只管傳送，低延遲但是會出現訊息的丟失，在某個server失敗的情況下，有點像 tcp
##1：傳送訊息，並會等待leader 收到確認後，一定的可靠性
## -1：傳送訊息，等待leader收到確認，並進行複製操作後，才返回，最高的可靠性
request.required.acks =0
新版本中只有這乙個引數 根據互動時間差來判斷是否移除isr
rerplica.lag.max.messages
Publisher的訊息確認機制
在前面的文章中提到了queue和consumer之間的訊息確認機制 通過設定ack。那麼publisher能不到知道他post的message有沒有到達queue，甚至更近一步，是否被某個consumer處理呢？畢竟對於一些非常重要的資料，可能publisher需要確認某個訊息已經被正確處理。在我們...
關於rabbitmq持久化及訊息確認總結
重啟rabbitmq服務通過兩個命令來實現 rabbitmqctl stop 停止rabbitmq rabbitmq server restart 重啟rabbitmq 檢視rabbitmq佇列資訊 rabbitmqctl list queues 持久化佇列資訊 durable，persistent...
RabbitMQ實戰 訊息確認機制之訊息的正確消費
上節中我們講了如何確保訊息的準確發布，今天我們來看看如何確保訊息的正確消費。在之前的基礎上我們對消費者 倉庫服務 進行完善。所以，首先我們將ack的方式設定為手動 spring rabbitmq host xx port 5672 username x password x listener dir...