KafkaSource 到camel-k 的集成无法转换CloudEvent

问题描述

我正在尝试创建一个使用骆驼集成作为接收器的 Kafka 源。

当我向 demo-topic 主题发送消息时，日志试图将消息转换为 CloudEvent 消息，但失败了。

我遵循了 Knative example 并且它有效。日志还显示该消息必须转换为 CloudEvent 消息。

有谁知道在使用 Camel 集成作为 Sink 时会导致处理错误的原因是什么？

卡夫卡来源：

apiVersion: sources.knative.dev/v1beta1
kind: KafkaSource
Metadata:
  name: kafka-source
  namespace: demo-cluster
spec:
  consumerGroup: demo-group
  bootstrapServers:
    - kafka-cluster-kafka-bootstrap.demo-cluster.svc:9092
    - kafka-cluster-kafka-bootstrap.demo-cluster.svc:9093
  topics:
    - demo-topic
  sink:
    ref:
      apiVersion: serving.knative.dev/v1
      kind: Service
      name: camel-api

日志：

{"level":"info","ts":"2021-04-07T14:53:42.435Z","caller":"consumer/consumer_handler.go:67","msg":"Starting partition consumer,topic: demo-topic,partition: 0,initialOffset: -1"}
{"level":"debug","ts":"2021-04-07T14:54:32.236Z","caller":"consumer/consumer_handler.go:75","msg":"Message claimed","topic":"demo-topic","value":"SGVsbG8gV29ybGQh"}
{"level":"debug","caller":"adapter/message.go:57","msg":"Message is not a CloudEvent -> We need to translate it to a valid CloudEvent"}
{"level":"debug","ts":"2021-04-07T14:54:51.667Z","caller":"adapter/adapter.go:149","msg":"Unexpected status code{status code 11 404  <nil>}"}
{"level":"info","caller":"consumer/consumer_handler.go:83","msg":"Failure while handling a message","partition":0,"offset":29,"error":"404 Not Found"}
{"level":"error","caller":"adapter/adapter.go:111","msg":"An error has occurred while consuming messages occurred: ","error":"404 Not Found","stacktrace":"knative.dev/eventing-kafka/pkg/source/adapter.(*Adapter).start.func2\n\t/opt/app-root/src/go/src/knative.dev/eventing/pkg/source/adapter/adapter.go:111"}

Openshift cluster architecture

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）

knative knative-eventing knative-serving