Docs Menu
Docs Home
/
MongoDB Kafka Connector
/

Kafka Connector 튜토리얼 설정

이 섹션의 튜토리얼은 를 사용하는 개발 환경에서 Docker 실행되어 용 를 실행하는 MongoDB connector 데 필요한 종속성 및 구성을 Apache Kafka 패키징합니다. 튜토리얼을 진행하기 전에 개발 환경 설정 단계를 완료했는지 확인하세요.

  • 이 튜토리얼에 필요한 Docker 컨테이너를 다운로드하려면 Docker 계정을 만들거나 로그인하세요. 계정을 등록하고 Docker Desktop을 설치하는 방법을 알아보려면 Docker Hub 빠른 시작의 등록 및 다운로드 단계를 읽어보세요.

  • 터미널 앱과 셸입니다. MacOS 사용자의 경우 터미널 또는 유사한 앱을 사용하세요. Windows 사용자의 경우 PowerShell을 사용하세요.

  • 선택 사항. git 을 설치하여 설정 파일을 다운로드합니다. git을 설치하는 방법을 알아보려면 Git 다운로드 를 참조하세요. 페이지.

1

다음으로 다음 명령을 사용하여 튜토리얼 git 리포지토리를 복제합니다:

git clone https://github.com/mongodb-university/kafka-edu.git

git이 설치되어 있지 않다면 대신 zip 아카이브를 다운로드할 수 있습니다.

2

이 가이드의 명령 실행 방법에 대한 지침을 보려면 해당 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" 이라는 공유 네트워크에서 실행합니다.

mongo-kafka-base의 Docker Compose 컨테이너를 보여주는 다이어그램

명령이 성공적으로 완료되면 다음 텍스트가 출력됩니다.

...
Creating zookeeper ... done
Creating broker ... done
Creating schema-registry ... done
Creating connect ... done
Creating rest-proxy ... done
Creating mongo1 ... done
Creating mongo1-setup ... done
3

다음 명령을 실행 하여 개발 환경이 성공적으로 시작되었는지 확인합니다.

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

돌아가기

Tutorials