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