Build the event @return the built event @throws IllegalStateException if a required attribute is not configured

Set an extension with provided key and string value @param key key of the extension attribute @param value value of the extension attribute @return

@return a new CloudEvent v1 builder

Set the {@code source} of the event @param source source of the event @return self

Set the {@code id} of the event @param id id of the event @return self

Set the {@code type} of the event @param type type of the event @return self

Convert a {@link OffsetDateTime} to a RFC3339 compliant {@link String}. @param time the time to write as {@link String} @return the serialized time @

Set attribute with type {@link String}. This setter should not be invoked for specversion, because the writer should already know the specversion or b

Get the attribute of extension named {@code key}. @param key the name of the extension attribute @return the extension value in one of the valid type

Set the {@code data} of the event @param data data of the event @return self

@return The event data, if any, otherwise {@code null}

Returns the bytes representation of this data instance. <p> Note: depending on the implementation, this operation may be expensive. @return this data

@return the result of the expression evaluation, which could be a {@link String}, a {@link Integer} or a {@link Boolean}.

Map {@code data} to another {@link CloudEventData} instance. @param data the input data @return The new data @throws CloudEventRWException is anythin

Serialize a {@link CloudEvent} to a byte array. @param event the event to serialize. @return the byte representation of the provided event. @throws E

@return The content type to use when writing an event with this {@link EventFormat}.

Like {@link #toEvent(CloudEventDataMapper)}, but with the identity {@link CloudEventDataMapper}. @see #toEvent(CloudEventDataMapper)

Set the {@code time} of the event @param time time of the event @return self

@return instance of {@link EventFormatProvider}

Copy this builder, creating a new instance with same values. @return A new builder with same values of this instance

Set the {@code subject} of the event @param subject subject of the event @return self

@return a new CloudEvent v0.3 builder

Write the provided event as binary. @param event event to write. @return return value at the end of the write process.

Like {@link #deserialize(byte[], CloudEventDataMapper)}, but with the identity {@link CloudEventDataMapper}. @see #deserialize(byte[], CloudEventData

@return The version of the CloudEvents specification which the event uses

Get the extension attribute named {@code extensionName} @param extensionName the extension name @return the extension value in one of the valid types

Parse the expression with default parser instance. @param inputExpression input expression @return the parsed expression @throws ParseException if th

End the write with a data payload. @param data the data to write @return an eventual return value @throws CloudEventRWException if the message writer

@param attributeName the invalid attribute name @param clazz the type of the attribute @return a new {@link CloudEventRWException} instance

Evaluate the expression. @param evaluationRuntime the runtime instance to use to run the evaluation @param event the input event @return

@param value byte array to wrap @return byte array wrapped in a {@link BytesCloudEventData}, which implements {@link CloudEventData}.

@return Identifies the event. Producers MUST ensure that source + id is unique for each distinct event

Invoke the function logic. @param ctx the evaluation context @param evaluationRuntime the evaluation runtime @param event t

Resolve an event format starting from the content type. @param contentType the content type to resolve the event format @return null if no format was

@return A value describing the type of event related to the originating occurrence.

@return the raw result of the evaluation

Create a new builder starting from the values of the provided event. @param event event to copy values from @return the new builder

@return The context in which an event happened.

@return The non-null extension attributes names in this instance

Like {@link #read(CloudEventWriterFactory, CloudEventDataMapper)}, but with the identity {@link CloudEventDataMapper}. @param <W> The type of the {@l

A common way to get the media type of CloudEvents 'data'; @return If has a value, it MUST follows the <a href="https://tools.ietf.org/html/rfc2046">R

@return The message encoding

This wraps a {@link Throwable} in a new generic instance of this exception. @param cause the cause of the exception @return a new {@link CloudEventRW

Parse a {@link String} RFC3339 compliant as {@link OffsetDateTime}. @param time the value to parse as time @return the parsed {@link OffsetDateTime}

Common flow to parse an incoming message that could be structured or binary. @param contentTypeHeaderReader supplier that returns the content type h

Set the {@code datacontenttype} of the event @param dataContentType datacontenttype of the event @return self

@return uppercase name of the function

@param attributeName the invalid attribute name @param value the value of the attribute @param cause an optional cause identifying the

Compute the CloudEvents Expression Language type from a Java class. @param clazz the class to use @return the type, or any if the class is unrecogniz

Get the <a href="https://github.com/cloudevents/spec/blob/v1.0/spec.md#context-attributes">context attribute</a> named {@code attributeName} @param a

@return <a href="https://github.com/cloudevents/spec/blob/v1.0/spec.md#time">Timestamp</a> of when the occurrence happened

Write the provided event as structured. @param event event to write. @param format {@link EventFormat} to use to serialize the event. @return return

@return the arity, excluding the vararg parameter if {@code isVariadic() == true}

Create a {@link io.cloudevents.core.message.MessageWriter} to write a {@link org.apache.kafka.clients.producer.ProducerRecord}. @param topic the

@return Return the URI specifying the location of the schema for the provided data

Parse a string as {@link SpecVersion} @param sv String representing the spec version @return The parsed spec version @throws CloudEventRWException Wh

Read the context attributes and extensions using the provided writer @param writer context writer @throws CloudEventRWException if something went wro

Add a context attribute to the root element. @param name @param xsiType @param value

Create a {@link io.cloudevents.core.message.MessageReader} to read {@link ConsumerRecord}. @param record the record to convert to {@link io.cloudeven

Generate a map with cloudevents attributes as keys and header keys as values @param headerNameMapping mapper to generate the header name @param <V>