3.4. KRaft 모드에서 Kafka 클러스터 실행

프로세스

1. Kafka 클러스터의 고유 ID를 생성합니다.

   kafka-storage 툴을 사용하여 이 작업을 수행할 수 있습니다.

   /opt/kafka/bin/kafka-storage.sh random-uuid

   명령에서 ID를 반환합니다. KRaft 모드에서는 클러스터 ID가 필요합니다.

2. 클러스터의 각 노드에 대한 구성 속성 파일을 생성합니다.

   Kafka와 함께 제공된 예제의 파일을 기반으로 할 수 있습니다.

   1. 브로커, 컨트롤러 또는 브로커,컨트롤러로 역할을 지정

      예를 들어 결합된 역할에 대해 process.roles=broker 를 지정합니다.

   2. 0 부터 시작하여 클러스터의 각 노드에 대해 고유한 node.id 를 지정합니다.

      예: node.id=1.

   3. < node_id>@<hostname:port> 형식으로 controller.quorum.voECDSA 목록을 지정합니다.

      예를 들어 controller.quorum.vohaproxy=1@localhost:9093.

   4. 리스너를 지정합니다.

      • 각 리스너의 이름, 호스트 이름 및 포트를 구성합니다.

        예를 들어 listeners=PLAINTEXT:localhost:9092,CONTROLLER:localhost:9093.

      • broker 간 통신에 사용되는 리스너 이름을 구성합니다.

        예를 들어 inter.broker.listener.name=PLAINTEXT 입니다.

      • 컨트롤러 쿼럼에서 사용하는 리스너 이름을 구성합니다.

        예: controller.listener.names=CONTROLLER.

      • Kafka에 연결하기 위해 클라이언트에 알리는 각 리스너의 이름, 호스트 이름 및 포트를 구성합니다.

        예를 들어 advertise .listeners=PLAINTEXT:localhost:9092.

3. Kafka 클러스터의 각 노드에 대한 로그 디렉터리를 설정합니다.

   /opt/kafka/bin/kafka-storage.sh format -t <uuid> -c /opt/kafka/config/kraft/server.properties

   반환:

   Formatting /tmp/kraft-combined-logs

   <uuid>를 생성한 클러스터 ID로 바꿉니다. 클러스터의 각 노드에 동일한 ID를 사용합니다.

   브로커용으로 생성한 속성 파일을 사용하여 브로커 구성을 적용합니다.

   기본적으로 server.properties 구성 파일에 지정된 로그 디렉터리(log.dirs)는 /tmp/kraft-combined-logs 로 설정됩니다. 일반적으로 /tmp 디렉터리는 시스템 재부팅마다 지워지므로 개발 환경에만 적합합니다.

   쉼표로 구분된 목록을 추가하여 여러 로그 디렉터리를 설정할 수 있습니다.

4. 각 Kafka 노드를 시작합니다.

   /opt/kafka/bin/kafka-server-start.sh /opt/kafka/config/kraft/server.properties

5. Kafka가 실행 중인지 확인합니다.

   jcmd | grep kafka

   반환:

   process ID kafka.Kafka /opt/kafka/config/kraft/server.properties

   각 노드의 로그를 확인하여 KRaft 클러스터에 성공적으로 참여했는지 확인합니다.

   tail -f /opt/kafka/logs/server.log