MSK Serverless에서 데이터 생성 및 소비

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

1. 다음 명령을 실행하여 콘솔 생산자를 생성합니다.

   <path-to-your-kafka-installation>/bin/kafka-console-producer.sh --broker-list $BS --producer.config client.properties --topic msk-serverless-tutorial

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

3. 클라이언트 머신에 대한 연결을 열어 둔 다음, 새 창에서 해당 머신에 대한 별도의 두 번째 연결을 엽니다.

4. 클라이언트 머신에 대한 두 번째 연결을 사용하여 다음 명령으로 콘솔 소비자를 생성합니다. Replace my-endpoint 클러스터를 생성한 후 저장한 부트스트랩 서버 문자열을 사용합니다.

   <path-to-your-kafka-installation>/bin/kafka-console-consumer.sh --bootstrap-server my-endpoint --consumer.config client.properties --topic msk-serverless-tutorial --from-beginning

   콘솔 생산자 명령을 사용할 때 앞서 입력한 메시지가 표시되기 시작합니다.

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