14장. Kafka에 연결
Apache Kafka는 데이터를 가져오고 게시하는 데 사용할 수 있는 분산 스트리밍 플랫폼입니다. 통합에서는 사용자가 지정하는 Kafka 주제의 데이터를 구독하거나 지정하는 Kafka 항목에 게시할 수 있습니다. 이렇게 하려면 Fuse Online에서 클러스터에서 Kafka 브로커를 검색할 수 있습니다. 그런 다음 Kafka에 대한 연결을 생성하고 통합 흐름에 해당 연결을 추가합니다. 자세한 내용은 다음 항목에 있습니다.
14.1. Kafka 브로커/AMQ Streams 자동 검색 활성화 링크 복사링크가 클립보드에 복사되었습니다!
통합에서 AMQ Streams 인스턴스인 Kafka 브로커에 연결하려는 경우 Kafka 연결을 생성하기 전에 해당 브로커의 자동 검색을 활성화합니다. 이렇게 하면 Fuse Online에서 연결을 구성하는 데 필요한 Kafka 브로커 세부 정보를 제공할 수 있으므로 Kafka 연결이 더 쉬워집니다.
자동 검색을 활성화하려면 해당 계정에서 클러스터에 리소스를 볼 수 있는 OpenShift 사용자 계정 권한을 제공합니다. 사용자가 할당한 특정 권한은 계정이 브로커의 다른 하위 집합을 검색할 수 있도록 합니다.
사전 요구 사항
- OCP 온-사이트에서 Fuse Online을 실행하고 있습니다.
-
oc클라이언트 도구를 설치하고 Kafka 브로커의 자동 검색을 활성화하려는 클러스터에 연결되어 있습니다. - 클러스터 관리 권한이 있어야 합니다.
- 통합에서 연결하려는 Kafka 브로커(s)(AMQ Streams 인스턴스)는 Fuse Online과 동일한 클러스터에 설치됩니다.
절차
클러스터 관리 권한이 있는 계정으로 OpenShift에 로그인합니다. 예를 들면 다음과 같습니다.
$ oc login -u admin -p admin현재 프로젝트가 Fuse Online이 실행 중인 프로젝트인지 확인합니다. 현재 프로젝트를 보려면 다음 명령을 호출합니다.
$ oc project클러스터의 Kafka 브로커에
oc사용자 계정에 액세스할 수 있는 권한을 부여합니다. 클러스터를 구성하는 방법에 따라 부여해야 하는 권한이 결정됩니다. 예를 들어, Minishift의 Strimzi 클러스터의 경우 다음을 수행할 수 있습니다.클러스터에서 Kafka/Strimzi 리소스에 액세스할 수 있는 클러스터 역할을 생성합니다. 다음 예에서
kafkas.kafka.strimzi.io-view는 새 역할의 이름입니다.oc create clusterrole kafkas.kafka.strimzi.io-view --verb=get,list --resource=kafkas --resource=crd이 클러스터 역할을
oc사용자에게 추가합니다. 다음 예에서syndesis-server는oc사용자 계정의 이름입니다.oc adm policy add-cluster-role-to-user kafkas.kafka.strimzi.io-view -z syndesis-server
결과
Fuse Online에서 Kafka 연결을 생성할 때 연결 구성 페이지에 사용 가능한 Kafka 브로커가 표시됩니다. 연결에 액세스할 브로커를 선택합니다.