Kafka Connector 튜토리얼 설정
이 섹션의 튜토리얼은 를 사용하는 개발 환경에서 Docker 실행되어 용 를 실행하는 MongoDB connector 데 필요한 종속성 및 구성을 Apache Kafka 패키징합니다. 튜토리얼을 진행하기 전에 개발 환경 설정 단계를 완료했는지 확인하세요.
요구 사항:
이 튜토리얼에 필요한 Docker 컨테이너를 다운로드하려면 Docker 계정을 만들거나 로그인하세요. 계정을 등록하고 Docker Desktop을 설치하는 방법을 알아보려면 Docker Hub 빠른 시작의 등록 및 다운로드 단계를 읽어보세요.
터미널 앱과 셸입니다. MacOS 사용자의 경우 터미널 또는 유사한 앱을 사용하세요. Windows 사용자의 경우 PowerShell을 사용하세요.
선택 사항. git 을 설치하여 설정 파일을 다운로드합니다. git을 설치하는 방법을 알아보려면 Git 다운로드 를 참조하세요. 페이지.
Docker로 개발 환경 설정
튜토리얼 리포지토리 복제 또는 다운로드
다음으로 다음 명령을 사용하여 튜토리얼 git 리포지토리를 복제합니다:
git clone https://github.com/mongodb-university/kafka-edu.git
git이 설치되어 있지 않다면 대신 zip 아카이브를 다운로드할 수 있습니다.
개발 환경 실행
이 가이드의 명령 실행 방법에 대한 지침을 보려면 해당 OS와 일치하는 탭을 선택하세요.
bash 셸을 사용하여 리포지토리 또는 압축을 푼 아카이브 내에서 튜토리얼 디렉토리 "mongodb-kafka-base" 로 이동합니다. git을 사용하여 리포지토리를 복제한 경우 명령은 다음과 유사합니다.
cd kafka-edu/docs-examples/mongodb-kafka-base/
PowerShell을 사용하여 리포지토리 또는 압축을 푼 아카이브 내에서 튜토리얼 디렉토리 "mongodb-kafka-base"로 이동합니다. git을 사용하여 리포지토리 를 복제한 경우 명령은 다음과 유사합니다.
cd kafka-edu\docs-examples\mongodb-kafka-base\
다음 명령으로 Docker 이미지를 시작합니다:
docker-compose -p mongo-kafka up -d --force-recreate
참고
포트 매핑
샌드박스는 다음 서비스를 호스트 시스템의 포트에 매핑합니다.
샌드박스 MongoDB 서버가 호스트 시스템의 포트
35001
에 매핑됩니다.샌드박스 Kafka Connect JMX 서버는 호스트 장치의 포트
35000
에 매핑됩니다.
샌드박스를 시작하려면 해당 포트가 비어 있어야 합니다.
"mongo-kafka-base" 이미지는 튜토리얼에 필요한 모든 서비스를 포함하는 Docker 컨테이너를 생성하고, 다음 다이어그램과 같이 "mongodb-kafka-base_localnet" 이라는 공유 네트워크에서 실행합니다.
명령이 성공적으로 완료되면 다음 텍스트가 출력됩니다.
... Creating zookeeper ... done Creating broker ... done Creating schema-registry ... done Creating connect ... done Creating rest-proxy ... done Creating mongo1 ... done Creating mongo1-setup ... done
성공적인 설정 확인
다음 명령을 실행 하여 개발 환경이 성공적으로 시작되었는지 확인합니다.
docker exec mongo1 status
Docker 개발 환경이 성공적으로 설정된 경우 이 명령은 다음 정보를 출력해야 합니다.
Kafka topics: "topic": "docker-connect-status", "topic": "docker-connect-offsets", "topic": "docker-connect-configs", "topic": "__consumer_offsets", The status of the connectors: Currently configured connectors [] Version of MongoDB Connector for Apache Kafka installed: {"class":"com.mongodb.kafka.connect.MongoSinkConnector","type":"sink","version":"1.8.0"} {"class":"com.mongodb.kafka.connect.MongoSourceConnector","type":"source","version":"1.8.0"}
커넥터를 시작하지 않았으므로 상태 및 구성된 목록이 비어 있습니다.
개발 환경 설정이 완료되었으며 튜토리얼의 다음 단계로 진행할 수 있습니다.
팁
개발 환경 MongoDB에 연결
다음 연결 을 사용하여 개발 환경에서 실행 중인 에 연결할 수 MongoDB cluster string 있습니다.
mongodb://localhost:35001/?directConnection=true