12장. Kafka Bridge

프로세스

1. AMQ Streams Kafka Bridge 설치 아카이브와 함께 제공되는 application.properties 파일을 편집합니다.

   속성 파일을 사용하여 Kafka 및 HTTP 관련 속성을 지정하고 분산 추적을 활성화합니다.

   1. Kafka 소비자 및 생산자와 관련된 속성을 포함하여 표준 Kafka 관련 속성을 구성합니다.

      다음을 사용하십시오.

      • Kafka 클러스터에 대한 호스트/포트 연결을 정의하는 Kafka .bootstrap.servers
      • Kafka.producer.acks HTTP 클라이언트에 승인을 제공

      • Kafka.consumer.auto.offset.reset 에서 오프셋의 재설정을 관리하는 방법

        Kafka 속성 구성에 대한 자세한 내용은 Apache Kafka 웹 사이트를참조하십시오.

   2. Kafka 클러스터에 대한 HTTP 액세스를 활성화하도록 HTTP 관련 속성을 구성합니다.

      예를 들면 다음과 같습니다.

      http.enabled=true
      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

      1

      포트 8080에서 수신 대기할 Kafka 브리지의 기본 HTTP 구성입니다.

      2

      CORS를 활성화하려면 true 로 설정합니다.

      3

      쉼표로 구분된 허용된 CORS 원본 목록입니다. URL 또는 Java 정규식을 사용할 수 있습니다.

      4

      CORS에 허용되는 HTTP 메서드의 쉼표로 구분된 목록입니다.

   3. 분산 추적을 활성화하거나 비활성화합니다.

      bridge.tracing=jaeger

      속성에서 코드 주석을 제거하여 분산 추적을 활성화합니다.

프로세스

1. 아직 수행하지 않은 경우 AMQ Streams Kafka Bridge 설치 아카이브의 압축을 임의의 디렉터리에 풉니다.

2. 구성 속성을 매개변수로 사용하여 Kafka Bridge 스크립트를 실행합니다.

   예를 들면 다음과 같습니다.

   ./bin/kafka_bridge_run.sh --config-file=_path_/configfile.properties

3. 로그에 설치에 성공했는지 확인합니다.

   HTTP-Kafka Bridge started and listening on port 8080
   HTTP-Kafka Bridge bootstrap servers localhost:9092