消費者傳遞保證語義

Kafka服務器端並不會記錄消費者的消費位置,而是由消費者自己決定如何保存其消費的offset. 0.8.2版本之前消費者會將其消費位置記錄zookeeper中,在後面的新版本中,消費者爲了緩解zookeeper集羣的壓力,在Kafka服務器端添加了一個名字是__consusmer_offsets的內部topic,簡稱爲offset topic,他可以用來保存消費者提交的offset,當出現消費者
相關文章
相關標籤/搜索