Uploaded image for project: 'Camel'
  1. Camel
  2. CAMEL-20639

Support Strimzi KafkaTopic endpoint reference in Pipes

    XMLWordPrintableJSON

Details

    • Improvement
    • Status: Resolved
    • Major
    • Resolution: Fixed
    • 4.x
    • 4.6.0
    • camel-jbang
    • None
    • Unknown

    Description

      Add support for Strimzi KafkaTopic resources acting as source/sink in a Pipe. Enhance the JBang bind command to properly handle topic resources.

       

      apiVersion: camel.apache.org/v1
      kind: Pipe
      metadata:
        name: timer-to-kafka                  
      spec:
        source:
          ref:
            kind: Kamelet
            apiVersion: camel.apache.org/v1
            name: timer-source
          properties:
            message: "Hello Kafka!"
        sink:
          ref:
            kind: KafkaTopic
            apiVersion: kafka.strimzi.io/v1beta2
            name: my-topic
          properties:
            brokers: my-cluster-kafka-bootstrap:9092

       

       

      Attachments

        Issue Links

          Activity

            People

              christophd Christoph Deppisch
              christophd Christoph Deppisch
              Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: