15장. Kafka 클러스터에 대한 클라이언트 액세스 설정

프로세스

1. Kafka 생산자를 배포합니다.

   이 예에서는 Kafka 클러스터 my-cluster 에 연결하는 Kafka 생산자를 배포합니다.

   my-topic 이라는 항목이 생성됩니다.

   OpenShift에 Kafka 생산자 배포

   oc run kafka-producer -ti --image=registry.redhat.io/amq-streams/kafka-40-rhel9:3.0.1 --rm=true --restart=Never -- bin/kafka-console-producer.sh --bootstrap-server my-cluster-kafka-bootstrap:9092 --topic my-topic

2. 생산자가 실행 중인 콘솔에 메시지를 입력합니다.
3. Enter 를 눌러 메시지를 보냅니다.

4. Kafka 소비자를 배포합니다.

   소비자는 Kafka 클러스터 my-cluster 에서 my-topic 에 생성된 메시지를 사용해야 합니다.

   OpenShift에 Kafka 소비자 배포

   oc run kafka-consumer -ti --image=registry.redhat.io/amq-streams/kafka-40-rhel9:3.0.1 --rm=true --restart=Never -- bin/kafka-console-consumer.sh --bootstrap-server my-cluster-kafka-bootstrap:9092 --topic my-topic --from-beginning

5. 소비자 콘솔에 들어오는 메시지가 표시되는지 확인합니다.