如何刪除weblogicjmsdelayed狀態(tài)的消息？消消氣~你注意到的“Topichtmltrack_errorisn'talreadymarkedafterdeletion”是正常的。Kafka

如何刪除weblogicjmsdelayed狀態(tài)的消息？

消消氣~

你注意到的“Topichtmltrack_errorisn'talreadymarkedafterdeletion”是正常的。Kafka刪掉topic的過程事實上是異步的：命令行單單是遞交一個刪除再申請給到controller，并標(biāo)志該topic為“待刪除”狀態(tài)。當(dāng)然在Kafka服務(wù)器端唯一的刪除掉邏輯應(yīng)該要早傳送，正常情況下您不需要多等待一段時間topic自然會被完成刪掉。

kafka broker與topic的關(guān)系？

另一個相當(dāng)于的kafka服務(wù)器被被稱broker。broker收得到來自生產(chǎn)者的消息，為消息設(shè)置中偏移量，并并提交消息到磁盤保存到。broker為消費(fèi)者提供服務(wù)，對讀取數(shù)據(jù)主分區(qū)的請求做出了決定相應(yīng)，前往也并提交到磁盤上的消息。

Kafka的消息按照主題（Topic）并且分類，就好比是數(shù)據(jù)庫的表，也可以是文件系統(tǒng)里的文件夾。主題是可以被分為若干個分區(qū)（Partition），一個分區(qū)應(yīng)該是個遞交日志。消息以賞分的讀取分區(qū)，然后以先進(jìn)先出的順序讀取。特別注意，的原因一個主題像是包涵幾個分區(qū)，但根本無法在整個主題范圍內(nèi)可以保證消息的順序，但可以只要消息在單個分區(qū)內(nèi)的順序。主題是邏輯上的概念，在物理上，一個主題是橫跨多個服務(wù)器的。

云計算分布式消息隊列有哪些？

有以下幾種：

ActiveMQ：每個人一開始都建議使用ActiveMQ，但現(xiàn)在的確每個人都還沒有使用太。已通過如此大規(guī)模吞吐量方案不驗證，社區(qū)也不是很活躍。單臺機(jī)器的吞吐量為10,000級，并且吞吐量低的RocketMQ和Kafka。這是一個數(shù)量級，吶喊之聲為ms級，有較低數(shù)據(jù)丟失的可能性。

RabbitMQ：單機(jī)吞吐率是萬級，吞吐率比RocketMQ和Kafka低一個數(shù)量級，但是它適合中小企業(yè)，因為它具有友好的監(jiān)視和能維護(hù)界面，社區(qū)總體活躍，全都每月都有都會查找?guī)讉€版本，近年來，一些國內(nèi)的互聯(lián)網(wǎng)公司更多地建議使用了rabbitmq，但問題也很的確。RabbitMQ的吞吐量雖然相對較低。這是畢竟他做的實現(xiàn)機(jī)制比較比較忙碌不堪，但是該語言國內(nèi)會的太少。

RocketMQ：單機(jī)吞吐量為100,000級。RocketMQ還是奇異也可以支持高吞吐量的MQ。主題是可以都沒有達(dá)到數(shù)百或數(shù)千個級別，另外吞吐量將略微降到。這是RocketMQ的通常優(yōu)勢。在同一臺機(jī)器上，它也可以意見大量topic，可用性太高，源代碼是JAVA。

Kafka：單機(jī)吞吐量為100,000級。這是Kafka的的最優(yōu)勢，即高吞吐量。通常與大數(shù)據(jù)系統(tǒng)依靠先執(zhí)行實時數(shù)據(jù)算出，日志收集等場景。當(dāng)topic從數(shù)十個時變數(shù)百個時，吞吐量將大嚇會下降