7장. Kafka 클러스터에 대한 클라이언트 액세스 설정
AMQ Streams를 배포한 후 이 섹션의 절차에서는 다음을 수행하는 방법을 설명합니다.
- 배포를 확인하는 데 사용할 수 있는 생산자 및 소비자 클라이언트 예제를 배포합니다.
Kafka 클러스터에 대한 외부 클라이언트 액세스 설정
OpenShift 외부의 클라이언트의 Kafka 클러스터에 대한 액세스를 설정하는 단계는 더 복잡하며 Kafka 구성 요소 구성 절차에 대해 숙지해야 합니다.
7.1. 예제 클라이언트 배포 링크 복사링크가 클립보드에 복사되었습니다!
링크 복사링크가 클립보드에 복사되었습니다!
다음 절차에서는 생성한 Kafka 클러스터를 사용하여 메시지를 보내고 수신하는 예제 생산자 및 소비자 클라이언트를 배포하는 방법을 설명합니다.
사전 요구 사항
- Kafka 클러스터는 클라이언트에서 사용할 수 있습니다.
절차
Kafka 생산자를 배포합니다.
oc run kafka-producer -ti --image=registry.redhat.io/amq7/amq-streams-kafka-32-rhel8:2.2.2 --rm=true --restart=Never -- bin/kafka-console-producer.sh --bootstrap-server cluster-name-kafka-bootstrap:9092 --topic my-topic
oc run kafka-producer -ti --image=registry.redhat.io/amq7/amq-streams-kafka-32-rhel8:2.2.2 --rm=true --restart=Never -- bin/kafka-console-producer.sh --bootstrap-server cluster-name-kafka-bootstrap:9092 --topic my-topicCopy to Clipboard Copied! Toggle word wrap Toggle overflow - 생산자가 실행 중인 콘솔에 메시지를 입력합니다.
- Enter 를 눌러 메시지를 보냅니다.
Kafka 소비자를 배포합니다.
oc run kafka-consumer -ti --image=registry.redhat.io/amq7/amq-streams-kafka-32-rhel8:2.2.2 --rm=true --restart=Never -- bin/kafka-console-consumer.sh --bootstrap-server cluster-name-kafka-bootstrap:9092 --topic my-topic --from-beginning
oc run kafka-consumer -ti --image=registry.redhat.io/amq7/amq-streams-kafka-32-rhel8:2.2.2 --rm=true --restart=Never -- bin/kafka-console-consumer.sh --bootstrap-server cluster-name-kafka-bootstrap:9092 --topic my-topic --from-beginningCopy to Clipboard Copied! Toggle word wrap Toggle overflow - 소비자 콘솔에 들어오는 메시지가 표시되는지 확인합니다.