15.2. Kafka 브로커에 대한 연결 생성
통합에서 Kafka 주제의 데이터를 구독하거나 Kafka 항목에 데이터를 게시하려면 Kafka에 대한 연결을 생성한 다음 통합에 해당 연결을 추가합니다.
사전 요구 사항
- Kafka 브로커 /AMQ 스트림의 자동 검색 활성화에 설명된 대로 클러스터에서 Kafka 브로커의 자동 검색을 활성화했습니다. 또는 연결하려는 Kafka 브로커의 URI를 알고 있습니다.
- TLS(Transport Layer Security)를 사용하여 데이터를 암호화하려면 Kafka 브로커의 PEM 인증서 텍스트가 있습니다. 일반적으로 Kafka 서버 관리자에서 브로커 인증서 텍스트를 가져옵니다.
절차
- Fuse Online의 왼쪽 패널에서 연결을 클릭하여 사용 가능한 연결을 표시합니다.
- 연결 만들기를 클릭하여 커넥터를 표시합니다.
- Kafka Message Broker 커넥터를 클릭합니다.
- Kafka 브로커 URI 필드에서 이 연결에 액세스할 브로커를 선택하거나 Kafka 브로커 URI의 쉼표로 구분된 목록을 입력합니다. 각 URI는 host:port 형식이어야 합니다.
전송 프로토콜 필드의 경우 다음 옵션 중 하나를 선택합니다.
- 데이터를 암호화하여 전송 중에 보호하려면 TLS (Transport Layer Security)를 선택합니다.
- 데이터를 암호화하지 않으려면 Plain 을 선택한 다음 7 단계로 건너뜁니다.
- 5단계에서 TLS 를 선택한 경우 Broker 인증서 필드에서 Kafka 브로커의 PEM 인증서 텍스트를 붙여넣습니다.
- Validate 를 클릭합니다. Fuse Online은 즉시 연결의 유효성을 검사하려고 시도하며 유효성 검사에 성공했는지 여부를 나타내는 메시지를 표시합니다. 유효성 검사가 실패하면 입력 매개변수를 수정하고 다시 시도합니다.
- 유효성 검사가 성공하면 다음을 클릭합니다.
-
이름 필드에 이 연결을 다른 연결과 구별하는 데 도움이 되는 이름의 선택을 입력합니다. 예를 들어
Kafka West를 입력할 수 있습니다. - 설명 필드에 선택적으로 이 연결에 대해 알 수 있는 정보를 입력합니다.
- 저장을 클릭하여 생성한 연결을 지금 사용할 수 있는지 확인합니다. 예제 이름을 입력하면 Kafka West 가 통합에 추가하도록 선택할 수 있는 연결로 표시되는 것을 확인할 수 있습니다.
