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과 동일한 클러스터에 설치됩니다.

절차

  1. 클러스터 관리 권한이 있는 계정으로 OpenShift에 로그인합니다. 예를 들면 다음과 같습니다.

    $ oc login -u admin -p admin
    Copy to Clipboard Toggle word wrap
  2. 현재 프로젝트가 Fuse Online이 실행 중인 프로젝트인지 확인합니다. 현재 프로젝트를 보려면 다음 명령을 호출합니다.

    $ oc project
    Copy to Clipboard Toggle word wrap
  3. 클러스터의 Kafka 브로커에 oc 사용자 계정에 액세스할 수 있는 권한을 부여합니다. 클러스터를 구성하는 방법에 따라 부여해야 하는 권한이 결정됩니다. 예를 들어, Minishift의 Strimzi 클러스터의 경우 다음을 수행할 수 있습니다.

    1. 클러스터에서 Kafka/Strimzi 리소스에 액세스할 수 있는 클러스터 역할을 생성합니다. 다음 예에서 kafkas.kafka.strimzi.io-view 는 새 역할의 이름입니다.

      oc create clusterrole kafkas.kafka.strimzi.io-view --verb=get,list --resource=kafkas --resource=crd
      Copy to Clipboard Toggle word wrap
    2. 이 클러스터 역할을 oc 사용자에게 추가합니다. 다음 예에서 syndesis-serveroc 사용자 계정의 이름입니다.

      oc adm policy add-cluster-role-to-user kafkas.kafka.strimzi.io-view -z syndesis-server
      Copy to Clipboard Toggle word wrap

결과

Fuse Online에서 Kafka 연결을 생성할 때 연결 구성 페이지에 사용 가능한 Kafka 브로커가 표시됩니다. 연결에 액세스할 브로커를 선택합니다.

맨 위로 이동
Red Hat logoGithubredditYoutubeTwitter

자세한 정보

평가판, 구매 및 판매

커뮤니티

Red Hat 문서 정보

Red Hat을 사용하는 고객은 신뢰할 수 있는 콘텐츠가 포함된 제품과 서비스를 통해 혁신하고 목표를 달성할 수 있습니다. 최신 업데이트를 확인하세요.

보다 포괄적 수용을 위한 오픈 소스 용어 교체

Red Hat은 코드, 문서, 웹 속성에서 문제가 있는 언어를 교체하기 위해 최선을 다하고 있습니다. 자세한 내용은 다음을 참조하세요.Red Hat 블로그.

Red Hat 소개

Red Hat은 기업이 핵심 데이터 센터에서 네트워크 에지에 이르기까지 플랫폼과 환경 전반에서 더 쉽게 작업할 수 있도록 강화된 솔루션을 제공합니다.

Theme

© 2025 Red Hat