0

我想在一個Spring引導應用程序中創建多個Kafka使用者組以處理不同的Kafka隊列。需求場景基於消息的臨界性,它應該推送到不同的Kafka隊列。爲了管理不同的卡夫卡隊列,我想創建一個專門的卡夫卡用戶組。但我不確定在一次春季啓動應用程序中是否可以創建多個卡夫卡消費羣。如何在一個Spring引導應用程序中創建多個Kafka Consumer Group

目前我有三個卡夫卡主題,每個主題有4個分區,只有一個卡夫卡消費者組和三個卡夫卡消費者。這三名卡夫卡消費者從三個專用卡夫卡隊列中讀取。

我使用Google搜索,但無法找到關於此的任何線索。

回答

1

你的問題不清楚,聽起來像你不完全熟悉卡夫卡。 首先在卡夫卡叫topic,不是隊列。這是主題的概念,因爲我們可以訂閱不同的消費者羣體以獲得相同的消息 - 發佈 - 訂閱者語義。

還不清楚爲什麼你需要幾個消費者羣體,因爲即使在同一個羣體中,不同的消費者可以從不同的主題消費。

反正你應該考慮使用:

/** 
* Override the {@code group.id} property for the consumer factory with this value 
* for this listener only. 
* @return the group id. 
* @since 1.3 
*/ 
String groupId() default ""; 

@KafkaListener你的目的。

相關問題