0
분산 캐시 동기화 메커니즘으로 압축 된 주제로 Confluent/Apache Kafka 0.10을 사용하고 있습니다. 응용 프로그램이 시작되면 인스턴스 특정 소비자 그룹 ID가 생성됩니다. 인스턴스가 수평 확장 성을 위해 추가되고 제거됨에 따라 분명히 우리는 다시는 사용되지 않아야하는 많은 수의 그룹 ID를 얻습니다.사용하지 않은 kafka 소비자 그룹 삭제
저는 이것이 KStreams와 KTables를위한 완벽한 유스 케이스라고 확신합니다.하지만 나는 KStreams와 KTables가 0.10에서 알파 품질로 정의되어 있다는 것뿐만 아니라 지적 이유 때문에 이것을 직접하려고 노력하고 있습니다.
기존 소비자 그룹을 삭제할 수있는 Kafka API 호출이 있습니까? 다시 사용하면 안된다는 것을 알고 있습니까?
Zookeeper는 0.10 버전에서 소비자 오프셋을 유지 관리하지 않으므로 kafka 자체에서이 작업을 수행 할 수 있어야한다고 생각합니다.
내가 상상 한 오프셋이 아닙니다. 모니터 툴링에 나타날 수있는 소비자 그룹이 많습니다. 내 응용 프로그램이 소비자 그룹을 만들고 내 응용 프로그램이 소비자 그룹을 삭제할 것을 알고있는 경우. 그렇다면 API 호출이있을 수 있다고 생각합니다. 어쩌면 기능 요청일까요? –
AFAIK, 모니터링 도구는 오프셋 로그를 읽고 표시된 정보를 수집합니다. 따라서 오프셋을 삭제하는 것은 소비자 그룹을 삭제하는 것과 동일하다고 가정합니다. –
감사합니다. 우리는 무슨 일이 일어날지를 볼 것입니다. 내 kafka 관리자가 모든 소비자 그룹 때문에 나를 죽이려고 돌아 오지 않는다면 나는 돌아와 이것을 대답으로 표시 할 것이다 :-) –