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.
35
questions
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");. ...
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 ...
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'...
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'&...
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 ...
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....
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 ...
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/...
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 ...
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.
...
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 ...
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 ...
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 = "{}"; // ...
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&...
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 ...
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()...
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, ...
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
...
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 ...
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{
...
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 &...
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.
-...
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 ...
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 ...
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 ...
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 ...
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 ...
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 ...
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 ...
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 ...
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 ...
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 ...
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 ...
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 ...
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-...