Questions tagged [cloudevents]

CloudEvents is a specification for describing event data in a common way. CloudEvents seeks to ease event declaration and delivery across services, platforms and beyond.

Filter by
Sorted by
Tagged with
0 votes
1 answer
20 views

Does CloudEventDeserializer deserialize custom extensions (kafka headers)?

I have cloudevent instance build using io.cloudevents.core.v1.CloudEventBuilder builder and I gave it custom extension using method builder.withExtension("whatever", "whatever");. ...
Martin Mucha's user avatar
  • 2,445
0 votes
0 answers
20 views

Commands in CloudEvents specification

We are adopting CloudEvents specification in my organization. I really like the idea and how the specification provides a common way of defining events along with handy tools to process them. I was ...
Jesus Eiroa's user avatar
0 votes
1 answer
78 views

Google Cloud Function: 'NotFound' Error When Using Blob.rewrite() to Copy Files Between Buckets

I'm encountering a 'NotFound' error while attempting to use the Blob.rewrite() method to copy files from one Google Cloud Storage bucket to another within a Google Cloud Function. The error message I'...
Someone's user avatar
  • 188
0 votes
1 answer
84 views

AttributeError: 'Blob' object has no attribute 'copy_to' in Google Cloud Function using python for transfering file from one bucket to another bucket

I am trying to transfer a file from one bucket to another bucket using Python code in Google Cloud Function but I am getting this error "AttributeError: 'Blob' object has no attribute 'copy_to'&...
Amazon King's user avatar
0 votes
1 answer
30 views

"address not set" error in a Broker-Trigger configuration with Event Display

Trying something really basic here to start things out. Service "event-display-task1" is using the Go Event Display without issues. My service "event-display-task2" is a simple ...
Tom's user avatar
  • 302
0 votes
0 answers
275 views

CloudEvent Jackson deserialize to POJO

I am trying to consume messages wrapped by CloudEvents.V1 in Kotlin I checked on documentation (doc) and applied the same idea as in Java. My event is built as: CloudEventBuilder.v1() .withId(UUID....
user3806586's user avatar
0 votes
0 answers
25 views

Classcastexception for CloudEventMessageConverter to AbstractMessageConverter

when using spring cloud stream latest version with cloud events spring sdk Facing classcastexception in below scenario. Message has contentType = application/*+avro. SmartcompositeMessageConverter ...
inaitgaJ's user avatar
  • 1,428
1 vote
1 answer
659 views

TypeScript types with Google Cloud Functions and Cloud Events

I'm using TypeScript to write some Cloud Functions (Gen 2) in GCP that are triggered by a PubSub message. Right now my code looks like this: import { CloudEvent, cloudEvent } from "@google-cloud/...
Jackson Christoffersen's user avatar
0 votes
1 answer
294 views

How to define a message fixed field value in AsyncAPI

We are looking at using CloudEvents as a message envelope for events generated in our system, and defining those messages using AsyncAPI. We are using the CloudEvents type property to identify each ...
PeeGee's user avatar
  • 99
0 votes
1 answer
197 views

Why Eventarc for inserJOb on bigquery generating 2 events for every insert?

I am working on a use case,where I need to trigger DAG when a bigquery table is inserted with some records. I am using Eventarc , and listening for insertJob event provided by Eventarc for bigquery. ...
Dipak Monty's user avatar
0 votes
1 answer
761 views

Batch Consumer not working with Kafka for CloudEvents using Spring Cloud Stream

Trying to read the batch messages for CloudEvents from cloud stream with Kafka binder. If I use any custom class with custom serializer/deserializer it is working fine but with cloudevents the ...
Sagar's user avatar
  • 3
0 votes
1 answer
199 views

Apache Kafka - Implementing a KTable and producing event using CloudEvent

I have an implementation related to KTable and using CloudEvents to produce events, but for some unknown reasons, the produced event from KTable is not formatted based on CloudEvent. The ...
Riat Abduramani's user avatar
0 votes
0 answers
476 views

String cannot be converted to CloudEvents

I am new to Kafka and trying to do some testing with a producer/consumer pair. I have a producer that looks like the below code. String key = "key1"; String message = "{}"; // ...
Nesan Mano's user avatar
  • 1,902
0 votes
1 answer
526 views

Java: How to read binary cloudevent

I want to process cloudevents created with python through knative broker ingress in a java kafka consumer. How do i get back the playload values from binary? Event Creation: attributes = { "type&...
Pierre's user avatar
  • 1,439
0 votes
0 answers
198 views

Lambda, Java and CloudEvents

I a have a Lambda function (java), which get triggered from Confluent Cloud Lambda Connector. The Lambda is being triggered but is failing because of deserialization errors. The signature is as ...
krisrr3's user avatar
  • 77
0 votes
0 answers
115 views

How can I learn my List<CloudEvent> size as MB or KB?

I am using CloudNative.CloudEvents nuget package from https://cloudevents.io/ for cloudevents issues. I am getting the below error in my extension for binary serializer by using SerializeToUtf8Bytes()...
Penguen's user avatar
  • 16.8k
1 vote
0 answers
173 views

Kafka headers are being overwritten by Kafka Source

I want to have Kafka message (cloud event) to be passed through Kafka Source -> Broker -> ASP.NET core service with headers from initial Kafka message. Right now I can put message with body, ...
Prox's user avatar
  • 11
1 vote
1 answer
734 views

How to handle schemas?

I have a small Spring-Boot-based prototype to publish messages to a Kafka cluster using Protobuf. I'm using the confluent serializer: io.confluent.kafka.serializers.protobuf.KafkaProtobufSerializer ...
Luciano Fiandesio's user avatar
2 votes
1 answer
507 views

Are CloudEvents useful on gRPC framework?

We have been working on an existing application that emits event for consumer applications. Consumer applications interact with our application on gRPC. We are evaluating CloudEvent standards for our ...
Pragmatic's user avatar
  • 3,093
1 vote
1 answer
2k views

Send data in cloudevents format to Kafka topic

Right now I have this code and it works fine. (It sends some json format data to Kafka topic) j, err := json.Marshal(data) if err != nil { log.Fatal(err) } msg := &sarama.ProducerMessage{ ...
Tom's user avatar
  • 355
0 votes
2 answers
287 views

Time datatype mismatch between Golang cloudEvent and proto

I am creating a proto file (and following cloudEvents standards). syntax = "proto3"; option go_package = "/events"; import "google/protobuf/timestamp.proto"; import &...
Pragmatic's user avatar
  • 3,093
0 votes
0 answers
388 views

Relaying a CloudEvent from HTTP POST to Kafka in Quarkus

I have an incoming io.cloudevents.CloudEvent object from HTTP POST, and would like to relay the object as-is to the Kafka topic using Quarkus using this approach. Is there a way to do this? Thanks. -...
codemasorete's user avatar
1 vote
0 answers
147 views

How to set exchanges in AMQP with cloudevents sdk-go

I need to send messages in rabbitMQ broker, but with use cloudevents sdk-go library based on azure-amqp protocol. I know how to set exchanges with streadway-amqp but I need to use a new version of ...
Pavel Monin's user avatar
0 votes
2 answers
747 views

How to reply with a CloudEvent using cloudevents sdk-javascript

I want to use Knative Sequence to chain few ksvcs but failed. The first step ksvc can be triggered but not the rest of them. In my ksvc(Node.js), I used CloudEvent js-sdk. I assume I would need to ...
watermelon's user avatar
0 votes
1 answer
596 views

Spring boot and CloudEvent AMQP binding

I'm trying to implement some CloudEvent demo. I have a hew spring boot services with RabbitMQ as a message bus they all send messages to a queue and one listens to the queue messages. I try to wrap my ...
Yaron's user avatar
  • 2,239
1 vote
1 answer
416 views

How does Event Grid + CloudEvents + Webhooks support updating the access_token?

CloudEvents has a webhooks specification for event delivery: HTTP 1.1 Web Hooks for Event Delivery - Version 1.0. Among other things, the CloudEvents Webhooks spec details requirements for webhook ...
Justin's user avatar
  • 6,031
3 votes
3 answers
4k views

Difference Avro Vs Cloudevent Vs AsyncAPI | Best fit for Schema evolution and naming convention in kafka

I am using confluent schema registry. What is the difference between Avro Vs Cloudevent Vs AsyncAPI What is the best fit for Schema evolution and naming convention in kafka ? Can we use different ...
VinuBibin's user avatar
  • 677
0 votes
1 answer
1k views

Azure Event Grid Cloud Events Schema V1.0 with Azure Event Grid Domains and Custom Topics Documentation Not Clear

I have elected to leverage Azure Event Grid in an enterprise multi-tenant model application. I also want to use Cloud Events instead of the proprietary AEG format. I am using AEG domains for each ...
Arra's user avatar
  • 43
1 vote
1 answer
6k views

Azure Event Grid Subscription WebHook Validation Fails with Cloud Events Schema v1.0

When attempting to create a WebHook Subscription, the deployment fails to validate an HTTP Trigger within Azure Functions for a Cloud Events v1.0 Schema.I have confirmed my endpoint handles the ...
Arra's user avatar
  • 43
2 votes
1 answer
3k views

Flutter - how to read list from Firebase realtime database using model

[ Sorry for my bad English ] In this project I'm viewing events lists in some pages from JSON API and in CloudEvents page I'm viewing another list from Firebase Database, using Event model ... Now ...
Salah Rashad's user avatar
0 votes
1 answer
292 views

Has anyone consumed a CNCF CloudEvent from Apache Kafka?

I have published several CNCF CloudEvents onto a Kafka Broker. I am trying to view them directly on the broker using this command: kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic ...
Miriah Peterson's user avatar
7 votes
1 answer
2k views

What tools to use on documenting event schema

Our team is starting to implement event driven designs. We are now figuring what's the best tool/s and practices for documenting the schema of these events. What are the common tools used for this ...
froi's user avatar
  • 7,308
1 vote
2 answers
2k views

What is the subscription validation event message schema in azure event grid?

Created new azure event grid domain with cloud event schema using portal. Created new web hook endpoint using azure function that can receive both subscription validation event as well as event ...
Raghu's user avatar
  • 2,889
0 votes
1 answer
149 views

Does Azure Event Grid support cloud event schema version 0.2?

I know that the AEG (azure event grid) works with cloud schema 0.1 as shown here https://learn.microsoft.com/en-us/azure/event-grid/cloudevents-schema#cloudevent-schema. But the cloud event schema ...
Raghu's user avatar
  • 2,889
2 votes
1 answer
856 views

posting custom message to event grid via logicapps

I'm using the Publish Event in logicapp { "error": { "code": "BadRequest", "message": "Unexpected token when reading JSON. Expected: StartObject, actual: StartArray. Report '01a24d3c-...
John Liu's user avatar
  • 1,334