2.5. Kafka 연결 내의 데이터에 작업 적용

절차

1. Kamelet 바인딩을 편집하여 topic-name-matches-filter-action Kamelet을 소스와 sink Kamelets 간의 중간 단계로 포함합니다.

   일반적으로 kafka-source Kamelet을 소스 Kamelet으로 사용하며 필요한 topic 매개변수의 값으로 주제를 제공합니다.

   다음 Kamelet Binding 예에서 kafka-source Kamelet은 test-topic, test-topic-2 및 test-topic-3 Kafka 주제와 topic-matches-filter-action Kamelet을 지정하여 topic-test 주제에서 이벤트 데이터를 필터링합니다.

   apiVersion: camel.apache.org/v1alpha1
   kind: KameletBinding
   metadata:
     name: kafka-to-log-by-topic
   spec:
     source:
       ref:
         kind: Kamelet
         apiVersion: camel.apache.org/v1alpha1
         name: kafka-source
       properties:
         bootstrapServers: "broker.url:9092"
         password: "testpassword"
         topic: "test-topic, test-topic-2, test-topic-3"
         user: "testuser"
         securityProtocol: "PLAINTEXT" // only for AMQ streams
   steps:
     - ref:
         kind: Kamelet
         apiVersion: camel.apache.org/v1alpha1
         name: topic-name-matches-filter-action
       properties:
         regex:  "test-topic"
   sink:
       ref:
         kind: Kamelet
         apiVersion: camel.apache.org/v1alpha1
         name: log-sink
       properties:
           showStreams: true

   Copy to Clipboard Toggle word wrap

   kafka-source Kamelet 이외의 소스 Kamelet에서 제공하는 항목을 필터링하려면 Kafka 주제 정보를 제공해야 합니다. 다음 예와 같이 insert-header-action Kamelet을 사용하여 Kafka topic 필드를 중개 단계로 추가할 수 있습니다. 이 필드는 Kamelet Binding의 topic-name-matches-filter-action 단계에서 다음과 같습니다.

   apiVersion: camel.apache.org/v1alpha1
   kind: KameletBinding
   metadata:
     name: coffee-to-log-by-topic
   spec:
     source:
       ref:
         kind: Kamelet
         apiVersion: camel.apache.org/v1alpha1
         name: coffee-source
       properties:
         period: 5000
   steps:
     - ref:
         kind: Kamelet
         apiVersion: camel.apache.org/v1alpha1
         name: insert-header-action
       properties:
         name:  "KAFKA.topic"
         value:  "test-topic"
     - ref:
         kind: Kamelet
         apiVersion: camel.apache.org/v1alpha1
         name: topic-name-matches-filter-action
       properties:
         regex:  "test-topic"
   sink:
       ref:
         kind: Kamelet
         apiVersion: camel.apache.org/v1alpha1
         name: log-sink
       properties:
         showStreams: true

   Copy to Clipboard Toggle word wrap
2. Kamelet Binding YAML 파일을 저장합니다.