5단계: 데이터 생산 및 소비

메시지를 생산하고 소비하려면

1. 콘솔 생산자를 시작하려면 다음 명령을 실행합니다.

   $KAFKA_ROOT/bin/kafka-console-producer.sh --broker-list $BOOTSTRAP_SERVER --producer.config $KAFKA_ROOT/config/client.properties --topic MSKTutorialTopic

2. 원하는 메시지를 입력하고 Enter키를 누릅니다. 이 단계를 두 번 또는 세 번 반복하십시오. 한 줄을 입력하고 Enter를 누를 때마다, 그 줄은 Apache Kafka 클러스터에 별도의 메시지로 전송됩니다.

3. 클라이언트 머신에 대한 연결을 열어 둔 다음, 새 창에서 해당 머신에 대한 별도의 두 번째 연결을 엽니다. 새 세션이므로 KAFKA_ROOT 및 BOOTSTRAP_SERVER 환경 변수를 다시 설정합니다. 이러한 환경 변수를 설정하는 방법에 대한 자세한 내용은 섹션을 참조하세요클라이언트 머신에서 주제 생성.

4. 클라이언트 시스템에 대한 두 번째 연결 문자열로 다음 명령을 실행하여 콘솔 소비자를 생성합니다.

   $KAFKA_ROOT/bin/kafka-console-consumer.sh --bootstrap-server $BOOTSTRAP_SERVER --consumer.config $KAFKA_ROOT/config/client.properties --topic MSKTutorialTopic --from-beginning

   콘솔 생산자 명령을 사용할 때 이전에 입력한 메시지가 표시되기 시작해야 합니다.

5. 생산자 창에 메시지를 더 입력하고 소비자 창에 메시지가 표시되는지 확인합니다.