Uploaded image for project: 'Red Hat Fuse'
  1. Red Hat Fuse
  2. ENTESB-17177

Operator 1.4 not working well with AMQ-Streams Operator 1.8

XMLWordPrintable

    • Icon: Bug Bug
    • Resolution: Done
    • Icon: Blocker Blocker
    • camel-k-1.6-GA
    • Camel-K-GA
    • Camel-K
    • None
    • False
    • False
    • % %
    • CK2
    • Todo
    • undefined
    • Hide

      The issue detected occurs when constructing a KameletBinding that involves AMQ-Streams.

      1) Deploy in OCP the default AMQ-Streams Operator (v 1.8 at the time of writing)

      2) Create a Kafka instance

      3) Deploy the default Red Hat Camel K Operator (1.4 at the time of writing)

      4) Create an Integration Platform

      5) Deploy a KameletBinding that involves AMQ-Streams

      here's an example:

      pre-conditions:

      > the chuck-norris-source kamelet needs to be deployed

      > the KafkaTopic 'jokes' needs to be created

      apiVersion: camel.apache.org/v1alpha1
      kind: KameletBinding
      metadata:
      name: jokes-producer
      spec:
      source:
      ref:
      apiVersion: camel.apache.org/v1alpha1
      kind: Kamelet
      name: chuck-norris-source
      sink:
      ref:
      apiVersion: kafka.strimzi.io/v1beta1
      kind: KafkaTopic
      name: jokes

       

      The error the Operator throws is:

      {"level":"error","ts":1629800796.051754,"logger":"controller-runtime.manager.controller.kamelet-binding-controller","msg":"Reconciler error","name":"jokes-producer","namespace":"demo-camelk","error":"could not determine sink URI: the server could not find the requested resource (get kafkas.kafka.strimzi.io my-cluster)","errorVerbose":"the server could not find the requested resource (get kafkas.kafka.strimzi.io my-cluster)\ncould not determine sink URI\ngithub.com/apache/camel-k/pkg/controller/kameletbinding.createIntegrationFor\n\tgithub.com/apache/camel-k/pkg/controller/kameletbinding/common.go:84\ngithub.com/apache/camel-k/pkg/controller/kameletbinding.(*initializeAction).Handle\n\tgithub.com/apache/camel-k/pkg/controller/kameletbinding/initialize.go:53\ngithub.com/apache/camel-k/pkg/controller/kameletbinding.(*ReconcileKameletBinding).Reconcile\n\tgithub.com/apache/camel-k/pkg/controller/kameletbinding/kamelet_binding_controller.go:177\ngithub.com/apache/camel-k/pkg/util/monitoring.(*instrumentedReconc...
      Show
      The issue detected occurs when constructing a KameletBinding that involves AMQ-Streams. 1) Deploy in OCP the default AMQ-Streams Operator (v 1.8 at the time of writing) 2) Create a Kafka instance 3) Deploy the default Red Hat Camel K Operator (1.4 at the time of writing) 4) Create an Integration Platform 5) Deploy a KameletBinding that involves AMQ-Streams here's an example: pre-conditions: > the chuck-norris-source kamelet needs to be deployed > the KafkaTopic 'jokes' needs to be created apiVersion: camel.apache.org/v1alpha1 kind: KameletBinding metadata: name: jokes-producer spec: source: ref: apiVersion: camel.apache.org/v1alpha1 kind: Kamelet name: chuck-norris-source sink: ref: apiVersion: kafka.strimzi.io/v1beta1 kind: KafkaTopic name: jokes   The error the Operator throws is: { "level" : "error" , "ts" :1629800796.051754, "logger" : "controller-runtime.manager.controller.kamelet-binding-controller" , "msg" : "Reconciler error" , "name" : "jokes-producer" , "namespace" : "demo-camelk" , "error" : "could not determine sink URI: the server could not find the requested resource (get kafkas.kafka.strimzi.io my-cluster)" , "errorVerbose" :"the server could not find the requested resource (get kafkas.kafka.strimzi.io my-cluster)\ncould not determine sink URI\ngithub.com/apache/camel-k/pkg/controller/kameletbinding.createIntegrationFor\n\tgithub.com/apache/camel-k/pkg/controller/kameletbinding/common.go:84\ngithub.com/apache/camel-k/pkg/controller/kameletbinding.(*initializeAction).Handle\n\tgithub.com/apache/camel-k/pkg/controller/kameletbinding/initialize.go:53\ngithub.com/apache/camel-k/pkg/controller/kameletbinding.(*ReconcileKameletBinding).Reconcile\n\tgithub.com/apache/camel-k/pkg/controller/kameletbinding/kamelet_binding_controller.go:177\ngithub.com/apache/camel-k/pkg/util/monitoring.(*instrumentedReconc...

      This is an issue raised for awareness.

      Although the documentation declares Camel K 1.4 is supported with AMQ-Streams 1.7, compatibility with AMQ-Streams 1.8 is broken.

      A normal user would tipically deploy the default AMQ-Streams Operator which deploys version 1.8, with which CamelK encounters problems. 

              nicolaferraro Nicola Ferraro (Inactive)
              bmesegue@redhat.com Bruno Meseguer
              Lucie Krejcirova Lucie Krejcirova
              Votes:
              0 Vote for this issue
              Watchers:
              4 Start watching this issue

                Created:
                Updated:
                Resolved: