JAVA面試如何保證消息不被重復(fù)消費？如何保證消息消費的冪等性？我沒事，來這里玩，開始在各種網(wǎng)絡(luò)上尋找技術(shù)信息，之后以“頭條”為主。從尋找信息到交朋友。因為我覺得事情落后于時代，有人認(rèn)為，是因為自己水

JAVA面試如何保證消息不被重復(fù)消費？如何保證消息消費的冪等性？

我沒事，來這里玩，開始在各種網(wǎng)絡(luò)上尋找技術(shù)信息，之后以“頭條”為主。從尋找信息到交朋友。因為我覺得事情落后于時代，有人認(rèn)為，是因為自己水平不高。只是在心里想，無法實現(xiàn)現(xiàn)實

提交到kafka的消息可以撤回嗎？

1. 它不支持消息回滾。2它可以采用延遲發(fā)送策略來實現(xiàn)召回。三。召回策略不能滿足實時性要求。取舍在于業(yè)務(wù)需求

flume和Kafka有一些相同的功能，但總的來說，它們是完全不同的。它們的場景不同，但可以一起使用。

簡而言之，flume是一個分布式日志收集系統(tǒng)，它從各種服務(wù)器收集日志并將其傳輸?shù)街付ǖ奈恢?，如HDFS。

Kafka是一個分布式消息中間件，有自己的存儲，提供推拉數(shù)據(jù)訪問功能。

整個過程如下：

登錄服務(wù)器<--flume-->kafka-->hdfs-->離線計算

登錄服務(wù)器<--flume-->kafka-->storm

希望我的回答能對您有所幫助

日志采集系統(tǒng)flume和kafka有什么區(qū)別及聯(lián)系？

卡夫卡的分布式單元是分區(qū)。Kafka保證分區(qū)中的數(shù)據(jù)是有序的，而分區(qū)之間的數(shù)據(jù)不能保證順序。多分區(qū)的特性使Kafka在一定程度上具備了分布式消息傳遞的能力。

在業(yè)務(wù)中，我們需要將需要嚴(yán)格排序的數(shù)據(jù)放在一個分區(qū)上，同時，我們需要將可以分發(fā)到其他分區(qū)的消息放在一個分區(qū)上，以確保高性能。