새로운 소비자 API로 kafka 소비자 오프셋을 삭제하십시오.

Question

새로운 소비자 API를 사용할 때 소비자 오프셋을 삭제할 수 있습니까?

bin/kafka-consumer-groups.sh 출력 :

WARNING: Group deletion only works for old ZK-based consumer groups, and one has to use it carefully to only delete groups that are not active.

Answer 1

유일한 방법 수동 올바른 키와 페이로드 = NULL로 화제 메시지를 보낼 __consumer_offsets.

카프카는 잠시 (offsets.retention.minutes으로 설정) 모든 소비자 데이터를 삭제합니다. 기본적으로 24 시간입니다.