如果一個消費者羣體訂閱了多個主題分區，kafka如何決定首先閱讀哪個分區？

Question

我正在嘗試構建一個可以通過kafka主題讀取的應用程序，但我需要它具有「查看上一個」按鈕。我知道如何通過特定的分區來查找，但是是否有可能按照讀入的順序來回讀主題中的所有消息？我正在使用Java KafkaConsumer。

Answer 1

偏移量是每個分區，不同分區間的消息之間沒有排序。由於kafka不知道消費者從不同分區讀取消息的順序（不同分區可能從不同分區中的不同分區讀取），所以您無法按照讀取順序回顧主題中的所有消息。簇）。但是，您可以做的是在讀取消息時，在應用程序中進行緩衝處理，這樣可以讓您返回到緩衝區的容量。