Apache Kafka 에코시스템용 Azure Event Hubs로 마이그레이션
Azure Event Hubs는 Kafka 프로토콜을 사용하여 Event Hubs에 연결할 수 있는 Apache Kafka 엔드포인트를 제공합니다. 기존 Kafka 애플리케이션을 최소한으로 변경하면 Azure Event Hubs에 연결하여 Azure 에코시스템의 이점을 제공합니다. Event Hubs는 MirrorMaker를 비롯한 대부분의 기존 Kafka 애플리케이션에서 작동합니다. 자세한 내용은 Apache Kafka용 Event Hubs를 참조하세요.
사전 마이그레이션
Azure 계정 만들기
Azure 구독이 없는 경우 시작하기 전에 체험 계정을 만듭니다.
Event Hubs 네임스페이스 만들기
Event Hubs 네임스페이스 및 이벤트 허브를 만들려면 이벤트 허브 만들기 문서의 단계별 지침을 따릅니다.
Connection string
포털에서 연결 문자열 가져오기 문서의 단계를 따릅니다. 또한 나중에 사용할 수 있게 연결 문자열을 적어둡니다.
FQDN(정규화된 도메인 이름)
Event Hubs 네임스페이스를 가리키는 FQDN이 필요할 수도 있습니다. FQDN은 다음과 같이 연결 문자열 내에서 찾을 수 있습니다.
Endpoint=sb://mynamespace.servicebus.windows.net/;SharedAccessKeyName=XXXXXX;SharedAccessKey=XXXXXX
Event Hubs 네임스페이스가 퍼블릭이 아닌 클라우드에 배포된 경우 도메인 이름이 다를 수 있습니다(예: *.servicebus.chinacloudapi.cn, *.servicebus.usgovcloudapi.net 또는 *.servicebus.cloudapi.de).
마이그레이션
Kafka 클라이언트 구성 업데이트
Kafka 지원 이벤트 허브에 연결하려면 Kafka 클라이언트 구성을 업데이트해야 합니다. 구성을 찾는 데 문제가 있는 경우 애플리케이션에서 bootstrap.servers가 설정된 위치를 검색해 보세요.
애플리케이션의 적합한 위치에 다음 구성을 삽입합니다. 클라이언트가 Event Hubs Kafka 엔드포인트를 가리키도록 올바른 인증으로 bootstrap.servers 및 sasl.jaas.config 값을 업데이트합니다.
bootstrap.servers={MYNAMESPACE}.servicebus.windows.net:9093
request.timeout.ms=60000
security.protocol=SASL_SSL
sasl.mechanism=PLAIN
sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username="$ConnectionString" password="{CONNECTION STRING TO YOUR NAMESPACE}";
프레임워크에서 지원되는 구성이 아닌 경우 sasl.jaas.config SASL(Simple Authentication and Security Layer) 사용자 이름과 암호를 설정하고 대신 사용하는 데 사용되는 구성을 찾습니다. 사용자 이름은 $ConnectionString으로 설정하고, 암호는 Event Hubs 연결 문자열로 설정합니다.
마이그레이션 후
이벤트 허브로 이벤트를 전송하는 Kafka 애플리케이션을 실행합니다. 그런 다음, 이벤트 허브가 Azure Portal을 사용하여 이벤트를 수신하는지 확인합니다. Event Hubs 네임스페이스의 개요 페이지에서 메트릭 섹션의 메시지 뷰로 전환합니다. 페이지를 새로 고쳐 차트를 업데이트합니다. 메시지가 수신되었음을 표시하는 데 몇 초 정도 걸릴 수 있습니다.
다음 단계
Event Hubs 및 Kafka용 Event Hubs에 대해 자세한 내용은 다음 문서를 참조하세요.