Kafka 대기열에 쓰고 읽는 사이에 지연이있는 이유는 무엇입니까?

Question

나는 Kafka 대기열의 메시지를 소비하는 작업자 서비스를 작성했으며 몇 초마다 대기열에 메시지를 추가하는 테스트 스크립트도 작성했습니다.

내가 눈치 채지 못한 사실은 메시지가 대기열에 추가되는 동안 소비자가 한 번에 몇 분 동안 유휴 상태로 앉아있는 경우가 많다는 것입니다. 그런 다음 갑자기 소비자가 첫 번째 메시지를 받아 처리하고 나머지 메시지로 빠르게 이동합니다. 그래서 결국 결국 멈추지 만, 왜 처음에는 그러한 지연이 있었는지 궁금합니다.

Answer 1

지연 중에 소비자 그룹에 문의하여 그룹 코디네이터에게 할당하고 할당 된 파티션을 자동으로 가져옵니다.

수동 할당을 사용하면 지연이 줄어 듭니다.