還是說只能啟動幾套行程就是幾個consumer。同一個消費組的情況下，可以在一個行程中啟動多個consumer嗎？
需要開發的時候如何配置呢？
uj5u.com熱心網友回復：
當然可以，只是同一消費組下每個消費者是競爭關系，可以提升消費性能。
uj5u.com熱心網友回復：
首先，你的topic必須是多個磁區的。一個磁區，一個消費者組ID（consumerGroupId）只會有一個消費者實體去消費資料。
例如topic1有2個磁區，cgi1有3個消費者，只有2個消費者各自消費topic1的其中一個磁區，剩余1個獲取不到消費權限，沒有資料吐給他。
當其中一個消費者掛掉或者處理延遲超過配置閾值，此消費者會被broker視為掛掉，識訓消費權限，由空閑的那個代替掛掉的消費者，從掛掉消費者最后一次提交的offset開始重新消費。
關于上述機制，自行搜索【kafka isr】In-Sync Replica機制。無論是消費者還是磁區副本復制，都是遵循這個機制的。這是kafka最核心的知識點之一。
uj5u.com熱心網友回復：
所以我們最穩健的做法是 n個磁區有 n+x個消費者實體去消費，然后再通過相關業務機制，控制因為掛掉、替補造成的重復消費，降低其副作用。
uj5u.com熱心網友回復：
Quote: 參考 2 樓 LinkSe7en 的回復: uj5u.com熱心網友回復：
參考 4 樓 doublepotato 的回復: Quote: 參考 2 樓 LinkSe7en 的回復: uj5u.com熱心網友回復：
參考 4 樓 doublepotato 的回復: Quote: 參考 2 樓 LinkSe7en 的回復:
轉載請註明出處，本文鏈接：https://www.uj5u.com/qita/52620.html
標籤：分布式計算/Hadoop
上一篇：請問有人能打開看見統計seeing-theory的網站嗎
下一篇：Leetcode在線求助
