3장. Kafka 브리지 구성
구성 속성을 사용하여 Kafka 브리지 배포를 구성합니다. Kafka를 구성하고 Kafka와 상호 작용하는 데 필요한 HTTP 연결 세부 정보를 지정합니다. 구성 속성을 사용하여 Kafka 브리지에서 분산 추적을 활성화하고 사용할 수도 있습니다. 분산 추적을 사용하면 분산 시스템의 애플리케이션 간 트랜잭션 진행 상황을 추적할 수 있습니다.
OpenShift에서 Kafka 브리지
를 실행할 때 KafkaBridge 리소스를 사용하여 속성을 구성합니다.
3.1. Kafka 브리지 속성 구성
다음 절차에서는 Kafka 브리지에서 사용하는 Kafka 및 HTTP 연결 속성을 구성하는 방법을 설명합니다.
Kafka 관련 속성에 적절한 접두사를 사용하여 Kafka 브리지를 다른 Kafka 클라이언트로 구성합니다.
-
Kafka.
서버 연결 및 보안과 같은 생산자 및 소비자에 적용되는 일반 구성의 경우 -
소비자별 구성의 경우 Kafka.consumer
.는 소비자에게만 전달됩니다. -
생산자별 구성의 경우 Kafka.producer
.는 생산자에게만 전달됩니다.
Kafka 클러스터에 대한 HTTP 액세스를 활성화할 뿐만 아니라 HTTP 속성은 CORS(Cross-Origin Resource Sharing)를 통해 Kafka 브릿지에 대한 액세스 제어를 활성화하고 정의하는 기능을 제공합니다. CORS는 브라우저에서 두 개 이상의 원본에서 선택한 리소스에 액세스할 수 있는 HTTP 메커니즘입니다. CORS를 구성하려면 허용된 리소스 원본 및 HTTP 메서드 목록을 정의하여 액세스할 수 있습니다. 요청의 추가 HTTP 헤더는 Kafka 클러스터에 액세스할 수 있는 CORS 원본을 설명합니다.
사전 요구 사항
프로세스
Kafka Bridge 설치 아카이브와 함께 제공된
application.properties
파일을 편집합니다.속성 파일을 사용하여 Kafka 및 HTTP 관련 속성을 지정합니다.
Kafka 소비자 및 생산자와 관련된 속성을 포함하여 표준 Kafka 관련 속성을 구성합니다.
다음을 사용하십시오.
-
Kafka 클러스터에 대한 호스트/포트 연결을 정의하는 Kafka
.bootstrap.servers
-
Kafka.producer.acks
HTTP 클라이언트에 승인을 제공 Kafka.consumer.auto.offset.reset
에서 오프셋의 재설정을 관리하는 방법Kafka 속성 구성에 대한 자세한 내용은 Apache Kafka 웹 사이트를참조하십시오.
-
Kafka 클러스터에 대한 호스트/포트 연결을 정의하는 Kafka
Kafka 클러스터에 대한 HTTP 액세스를 활성화하도록 HTTP 관련 속성을 구성합니다.
예를 들면 다음과 같습니다.
Copy to Clipboard Copied! Toggle word wrap Toggle overflow bridge.id=my-bridge http.host=0.0.0.0 http.port=8080 http.cors.enabled=true http.cors.allowedOrigins=https://strimzi.io http.cors.allowedMethods=GET,POST,PUT,DELETE,OPTIONS,PATCH
bridge.id=my-bridge http.host=0.0.0.0 http.port=8080
1 http.cors.enabled=true
2 http.cors.allowedOrigins=https://strimzi.io
3 http.cors.allowedMethods=GET,POST,PUT,DELETE,OPTIONS,PATCH
4
- 구성 파일을 저장합니다.