问题标签 [cloudevents]

我正在尝试实现一些CloudEvent演示。
我有一个 hew spring boot 服务RabbitMQ作为消息总线，它们都将消息发送到队列，并且一个监听队列消息。
我尝试包装我的信息CloudEvent以使它们更标准。
我使用以下代码将消息（数据）包装为CloudEvent.

由于消息CloudEventData是基于字节的，因此数据被转换为字节。
当然，在我的侦听器方法上，由于SimpleMessageConverter无法处理字节数组，我得到了异常。现在，我可以尝试实现一些自定义消息处理程序或尝试查看CloudEventAMQP 建议的绑定解决方案，但我并不热衷于它涉及的代码量，如果不是绝对必要的话，我不想涉及更多技术。

1. 我应该走这条路并实现自定义消息转换器吗？
2. 是否有任何其他标准解决方案可以通过 qeeus 标准化服务消息传递？

我想使用 Knative Sequence 链接几个 ksvcs 但失败了。可以触发第一步 ksvc，但不能触发其余步骤。

在我的 ksvc(Node.js) 中，我使用了 CloudEvent js-sdk。我假设我需要在收到新的 CloudEvent 后返回它。所以这是我的代码：

我需要在 rabbitMQ 代理中发送消息，但是使用基于 azure-amqp 协议的 cloudevents sdk-go 库。我知道如何使用 stradway-amqp 设置交换，但我需要使用新版本的 amqp (1+)。对于这种情况，我需要使用 cloudevents sdk-go 库。我发现，当我们创建一个新协议时，我们设置了地址和节点。Node - 是代理中的消息队列。但我希望新协议创建一个交换，而不是一个队列。我怎么能这样做？我可以这样做吗？）

我有一个来自 HTTP POST 的传入 io.cloudevents.CloudEvent 对象，并且希望使用 Quarkus 使用这种方法将对象按原样中继到 Kafka 主题。有没有办法做到这一点？谢谢。

mp.messaging.outgoing.mytopic.value.serializer=??? mp.messaging.incoming.mytopic.value.deserializer=???

我想知道如何在我的 .proto 文件中使用 CloudEvent 标准。虽然在（.proto 文件）中表示必填字段是直截了当的，但我如何表示应该单独序列化的数据（根据 cloudEvents）？

我遇到了这个链接https://github.com/cloudevents/spec/blob/v1.0.1/protobuf-format.md但缺少示例。如果有人可以分享一些例子，那将非常有帮助。

谢谢

我正在创建一个原型文件（并遵循 cloudEvents 标准）。

它在客户端和服务器之间运行良好。我们还想确保这个对象完全符合 cloudevents。测试一下如果我尝试使用 json.marshal() 编组这个对象，然后使用 json.unmarshal 解组到 cloudEvent 对象。在此测试中，由于 proto 对象和 cloudEvents 之间的时间字段数据类型不匹配，反序列化正在中断。

但是，如果我删除时间字段，一切正常。知道我错过了什么吗？

现在我有这个代码，它工作正常。（它将一些 json 格式的数据发送到 Kafka 主题）

但有人希望这些数据采用 cloudevents 格式。-> https://github.com/cloudevents/sdk-go 那么我该怎么办，因为这个事件结构不能直接转换为字符串。

所以这段代码甚至不会编译。

我应该怎么做才能将此事件发送到 Kafka？尝试将 event.DataEncoded 转换为字符串或类似的东西？顺便提一句。编程语言是golang。

我们一直致力于为消费者应用程序发出事件的现有应用程序。消费者应用程序在 gRPC 上与我们的应用程序交互。

我们正在为我们的活动评估CloudEvent标准。虽然我们知道它提供了一个标准的信封（带有标准元数据属性），但我们想知道它对 gRPC 协议的好处将是有限的。

消费者使用从 .proto 文件生成的客户端存根，这些存根还为这些事件生成静态类。

消费者不能使用通用CloudEvents类（来自 SDK）。他们获得的唯一好处是，如果他们想将这些事件发送给他们的客户，他们可以将它们序列化并发送出去。他们的客户可以使用标准的 SDK 类来使用它们。

这种理解是正确的还是我们遗漏了什么？

谢谢

我希望能够通过 Github Webhooks使用 CloudEvents。

我正在使用sdk-go但没有通过，也许它不适用于 Github？

我想在我的 Knative 环境中实现 FaaS。所以我开始玩 Quarkus Funqy。我已按照官方 quickStarts 成功接收/发送 CloudEvent

在大多数示例中，CloudEvent 是作为 CloudEvent 的响应从函数发出的：

这对开发人员来说非常简单，因为他不需要知道 CloudEvent 代理 URL 的任何细节。java方法返回的对象通过Quarkus内部机制发送给broker。

但就我而言，我想在函数调用之外发送一个 CloudEvent，例如一个 cron 作业：

是否有任何注释可以绑定到 Knative 消息代理。IE：

如果没有，我可以使用 CloudEvent，因为它们被发送到 HTTP POST，所以我可以使用 Quarkus HTTP 客户端。但是我怎样才能检索 Knative 消息代理端点？有注释吗？

谢谢，