Red Hat Summit14장. Kafka에 연결
Apache Kafka는 데이터를 가져오고 게시하는 데 사용할 수 있는 분산 스트리밍 플랫폼입니다. 통합에서는 사용자가 지정하는 Kafka 주제의 데이터를 구독하거나 지정하는 Kafka 항목에 게시할 수 있습니다. 이렇게 하려면 Kafka에 대한 연결을 생성한 다음 통합 흐름에 해당 연결을 추가합니다. 자세한 내용은 다음 항목에 있습니다.
14.1. Kafka 브로커에 대한 연결 생성
통합에서 Kafka 주제의 데이터를 구독하거나 Kafka 항목에 데이터를 게시하려면 Kafka에 대한 연결을 생성한 다음 통합에 해당 연결을 추가합니다.
중요
이번 릴리스에서는 Kafka에 대한 연결이 SSL을 지원하지 않습니다. 향후 릴리스에서 변경될 것으로 예상됩니다.
사전 요구 사항
연결하려는 Kafka 브로커의 URI를 알아야 합니다.
절차
- Fuse Online의 왼쪽 패널에서 연결을 클릭하여 사용 가능한 연결을 표시합니다.
- 오른쪽 상단에서 연결 만들기 를 클릭하여 커넥터를 표시합니다.
- Kafka 커넥터를 클릭합니다.
- Kafka 부트스트랩 URI 필드에 Kafka 브로커 URI의 쉼표로 구분된 목록을 입력합니다. 각 URI는 host:port 형식이어야 합니다.
- Validate 를 클릭합니다. Fuse Online은 즉시 연결의 유효성을 검사하려고 시도하며 유효성 검사에 성공했는지 여부를 나타내는 메시지를 표시합니다. 유효성 검사가 실패하면 입력 매개변수를 수정하고 다시 시도합니다.
- 유효성 검사가 성공하면 다음을 클릭합니다.
-
이름 필드에 이 연결을 다른 연결과 구별하는 데 도움이 되는 이름의 선택을 입력합니다. 예를 들어
Kafka West를 입력할 수 있습니다. - 설명 필드에 선택적으로 이 연결에 대해 알 수 있는 정보를 입력합니다.
- 저장을 클릭하여 생성한 연결을 지금 사용할 수 있는지 확인합니다. 예제 이름을 입력하면 Kafka West 가 통합에 추가하도록 선택할 수 있는 연결로 표시되는 것을 확인할 수 있습니다.
