卡卡消費抵消在保留後未被刪除

我試圖測試經紀人offset.retention.minutes=30的配置。我已將此配置更改爲10分鐘，而不是默認的24小時。卡卡消費抵消在保留後未被刪除

但是後超過10分鐘的消費羣體偏移仍顯示在信息

ldnpsr000001131$ bin/kafka-consumer-groups.sh --zookeeper localhost:2181 --describe -group rent_test 
GROUP       TOPIC       PARTITION CURRENT-OFFSET LOG-END-OFFSET LAG    OWNER 
rent_test      rent_test      0   44    44    0    none

任何想法，爲什麼它沒有被清除偏移？

來源

2017-03-02 Joey

只是爲了澄清，我使用'kafka_2.10-0.10.0.1'，以及我測試這種情況的原因，因爲我們正面臨消費者偏移在一段非活動消費者羣體之後丟失的問題。 – Joey

offsets.retention.minutes控制偏移量主題的日誌保留窗口，以分鐘爲單位，即__consumer_offsets，新消費者存儲偏移量。在使用舊用戶的情況下，偏移量將存儲在動物園管理員中，因此設置offsets.retention.minutes對基於ZK的使用者組沒有影響。

來源

2017-03-02 08:59:30 amethystic

我已經嘗試過與新的消費者，同時，我檢查了消費者羣體並找到了預期的消費者羣體。 'ldnpsr000001131 $ bin/kafka-consumer-groups.sh --bootstrap-server localhost：9092 --list -new-consumer rent_test'。但是，當我停止消費者，並再次檢查顯示此消息「消費者組'rent_test'不存在或正在重新平衡.'。我期待我們仍然可以檢查消費者抵消，即使沒有活躍的消費者羣體@amethystic – Joey

Kafka0.10.0.1只顯示活動羣組的信息，而0.10.2中的kafka-consumer-groups.sh（實際上我不記得是什麼確切的版本介紹了這種改進），這已經得到了很大的增強，能夠顯示失效組的偏移量。但是仍然有辦法檢查這些組的偏移量：直接查找__consumer_offsets。 – amethystic

我不明白爲什麼在更改爲使用kafka的新消費者之後（10分鐘）之後的保留期後，抵消消費者組沒有得到刪除0.10.0.1 @amethystic – Joey

卡卡消費抵消在保留後未被刪除

回答

相關問題