春季kafkatemplate相關編號

Question

目前我正在使用spring kafkatemplate向kafka主題發送字節消息。 在消費者方面，我們將此字節消息反序列化爲適當的消息類型。 現在我們已經要求我們還需要發送correlationid以及消息給Kafka主題。 我可以在kafka主題上發送關聯id和字節消息，並在消費者端分別檢索它嗎？

Answer 1

即將發佈的Kafka v0.11增加了對自定義消息標題的支持。他們將成爲關聯ID的主要候選人。

在此之前，恐怕您必須將關聯標識放入消息值中。您的序列化器和解串器應該將它與實際有效載荷一起編碼/解碼到字節數組中。

Answer 2

根據Kafka Docs， CorrelationId是用戶提供的整數。它將在未經修改的服務器響應中傳回。在客戶端和服務器之間匹配請求和響應很有用。

如果我談論java api，那麼在消費者方面，您只能獲得與消息相關的（topic_name，partition，offset，value）。

您可以發送correlationId作爲消息的一部分，但您必須解析該消息才能在消費者一方獲得。