consumer

[kangchanguk]

consumer group

• 하나의 토픽에 여러 컨슈머 그룹이 동시에 접속해 메세지를 가져올 수 있음
• 하나의 메시지를 다양한 용도로 사용할 수 있음

why consumer group

• consumer 확장이 용이
• 그룹이 아닌 consumer 추가 시 기존 consumer offset 정보와 새롭게 추가된 consumer offset 정보가 뒤섞여 메세지들이 뒤죽박죽이 됨

rebalance

• 컨슈머 그룹 안에서는 컨슈머들이 메세지를 가져오고 있는 토픽의 파티션에 대해 소유권을 공유함
• 컨슈머가 추가됨으로써 파티션에 대한 소유권이 이동하는 것을 rebalance라고 명명
• 컨슈머를 쉽게 추가 제거 가능해 높은 가용성과 확장성 확보가 가능
• rebalance를 하는 동안에는 consumer는 메세지를 가져올 수 없음(단점)

partition and consumer

• 하나의 partition에는 하나의 consumer만 연결(메세지 순서 보장을 위해)