kafka reassign1 kafka kafka-reassign-partitions.sh를 사용한 파티션 재할당 kafka-reassign-partitions는 아래와 같은 경우 사용된다. 브로커 간의 리더 불균형을 제어 한 브로커에서 다른 브로커로 파티션을 재할당하여 기존 클러스터를 확장 동일한 브로커의 로그 디렉토리 간에 파티션을 재할당하여 브로커에서 사용 가능한 디스크 간의 스토리지 로드 불균형을 해결 여러 브로커의 로그 디렉토리 간에 파티션을 재할당해 여러 브로커에서 스토리지 로드 불균형을 해결 test topic의 partition은 아래와 같이 분산되어 있다. # server01 [root@server01 ~]# ll -d /kafka/kafka-logs/t* drwxr-xr-x. 2 root root 204 Aug 23 07:12 /kafka/kafka-logs/test-2 [root@server01 .. 2022. 9. 13. 이전 1 다음 반응형