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.

34 questions
7
votes
1 answer

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 use case? Any links or suggestions is appreciated.
froi
  • 7,268
  • 5
  • 40
  • 78
3
votes
3 answers

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 schema types for different topics based on…
2
votes
1 answer

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 events. While we understand that it provides a…
Pragmatic
  • 3,093
  • 4
  • 33
  • 62
2
votes
1 answer

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 when I run CloudEvents page I get null for…
Salah Rashad
  • 408
  • 8
  • 18
2
votes
1 answer

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-7588-4580-b650-52aa4f25b805:9/8/2018 7:17:33 AM…
John Liu
  • 1,334
  • 1
  • 11
  • 16
1
vote
1 answer

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/functions-framework" interface PubsubMessageSentData…
1
vote
0 answers

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, headers and on Kafka, it's consumed by Kafka Source, but…
Prox
  • 11
  • 2
1
vote
1 answer

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…
1
vote
1 answer

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{ Topic: tName, Value:…
Tom
  • 355
  • 4
  • 13
1
vote
0 answers

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 amqp (1+). And for this case, I need to use…
1
vote
1 answer

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 validation and authorization. As described in the…
Justin
  • 6,031
  • 11
  • 48
  • 82
1
vote
1 answer

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 validation handshake with the appropriate response. My…
Arra
  • 43
  • 1
  • 6
0
votes
0 answers

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 wondering if there is something similar for…
Jesus Eiroa
  • 43
  • 1
  • 7
0
votes
1 answer

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'm receiving is as follows: NotFound: 404 POST…
0
votes
1 answer

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'". These are some additional details about the…
1
2 3