Red Hat Summit1장. Kafka 브리지 개요
Apache Kafka Bridge용 Streams를 사용하여 Kafka 클러스터에 HTTP 요청을 만듭니다.
Kafka 브리지를 사용하여 HTTP 클라이언트 애플리케이션을 Kafka 클러스터와 통합할 수 있습니다.
HTTP 클라이언트 통합
1.1. Kafka 브리지 실행
Kafka 클러스터와 동일한 환경에서 실행되도록 Apache Kafka 브리지용 Streams를 설치합니다.
호스트 머신에 Kafka Bridge 설치 아티팩트를 다운로드하여 추가할 수 있습니다. 로컬 환경에서 Kafka 브리지를 시도하려면 Kafka Bridge 빠른 시작을 참조하십시오.
Kafka 브리지의 각 인스턴스는 HTTP 클라이언트를 대신하여 Kafka 브로커에 연결하는 자체 메모리 내 소비자(및 서브스크립션) 세트를 유지 관리합니다. 즉, 생성된 서브스크립션에 액세스하려면 각 HTTP 클라이언트에서 동일한 Kafka Bridge 인스턴스에 대한 선호도를 유지해야 합니다. 또한 Kafka Bridge 인스턴스가 다시 시작되면 메모리 내 소비자 및 서브스크립션이 손실됩니다. Kafka Bridge가 다시 시작되면 HTTP 클라이언트에서 소비자와 서브스크립션을 다시 생성해야 합니다.
1.1.1. OpenShift에서 Kafka 브리지 실행
OpenShift에 Apache Kafka용 Streams를 배포하는 경우 Streams for Apache Kafka Cluster Operator를 사용하여 OpenShift 클러스터에 Kafka 브리지를 배포할 수 있습니다. Kafka 브리지를 KafkaBridge 리소스로 구성하고 배포합니다. OpenShift 네임스페이스에서 Cluster Operator가 배포한 실행 중인 Kafka 클러스터가 필요합니다. OpenShift 클러스터 외부에서 Kafka Bridge에 액세스하도록 배포를 구성할 수 있습니다.
HTTP 클라이언트는 생성한 모든 소비자 또는 서브스크립션에 액세스하려면 Kafka 브리지의 동일한 인스턴스에 대한 선호도를 유지해야 합니다. 따라서 OpenShift 배포당 Kafka 브리지의 여러 복제본을 실행하는 것은 권장되지 않습니다. Kafka Bridge 포드가 다시 시작되면(예: OpenShift에서 워크로드를 다른 노드로 재배치하기 때문에) HTTP 클라이언트는 소비자 또는 서브스크립션을 다시 생성해야 합니다.
Kafka Bridge 를 KafkaBridge 리소스로 배포하고 구성하는 방법에 대한 자세한 내용은 Streams for Apache Kafka 문서를 참조하십시오.
