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