io.smallrye.reactive.messaging.kafka.impl.ce

Class KafkaCloudEventHelper

java.lang.Object

io.smallrye.reactive.messaging.kafka.impl.ce.KafkaCloudEventHelper

public class KafkaCloudEventHelper
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	KafkaCloudEventHelper.CloudEventMode

Field Summary

Fields

Modifier and Type	Field and Description
static String	CE_CONTENT_TYPE_PREFIX
static String	CE_HEADER_PREFIX
static String	KAFKA_HEADER_CONTENT_TYPE
static String	KAFKA_HEADER_FOR_CONTENT_TYPE
static String	KAFKA_HEADER_FOR_ID
static String	KAFKA_HEADER_FOR_SCHEMA
static String	KAFKA_HEADER_FOR_SOURCE
static String	KAFKA_HEADER_FOR_SPEC_VERSION
static String	KAFKA_HEADER_FOR_SUBJECT
static String	KAFKA_HEADER_FOR_TIME
static String	KAFKA_HEADER_FOR_TYPE
static DateTimeFormatter	RFC3339_DATE_FORMAT
static String	STRUCTURED_CONTENT_TYPE

Method Summary

Modifier and Type	Method and Description
static org.apache.kafka.clients.producer.ProducerRecord<?,?>	createBinaryRecord(Message<?> message, String topic, OutgoingKafkaRecordMetadata<?> metadata, OutgoingCloudEventMetadata<?> ceMetadata, KafkaConnectorOutgoingConfiguration configuration)
static <T,K> IncomingKafkaCloudEventMetadata<K,T>	createFromBinaryCloudEvent(org.apache.kafka.clients.consumer.ConsumerRecord<?,T> record)
static <T,K> IncomingKafkaCloudEventMetadata<K,T>	createFromStructuredCloudEvent(org.apache.kafka.clients.consumer.ConsumerRecord<K,T> record)
static org.apache.kafka.clients.producer.ProducerRecord<?,?>	createStructuredRecord(Message<?> message, String topic, OutgoingKafkaRecordMetadata<?> metadata, OutgoingCloudEventMetadata<?> ceMetadata, KafkaConnectorOutgoingConfiguration configuration)
static KafkaCloudEventHelper.CloudEventMode	getCloudEventMode(org.apache.kafka.clients.consumer.ConsumerRecord<?,?> record)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

KAFKA_HEADER_CONTENT_TYPE

public static final String KAFKA_HEADER_CONTENT_TYPE

See Also:

Constant Field Values

CE_CONTENT_TYPE_PREFIX

public static final String CE_CONTENT_TYPE_PREFIX

See Also:

Constant Field Values

CE_HEADER_PREFIX

public static final String CE_HEADER_PREFIX

See Also:

Constant Field Values

STRUCTURED_CONTENT_TYPE

public static final String STRUCTURED_CONTENT_TYPE

See Also:

Constant Field Values

KAFKA_HEADER_FOR_SPEC_VERSION

public static final String KAFKA_HEADER_FOR_SPEC_VERSION

See Also:

Constant Field Values

KAFKA_HEADER_FOR_TYPE

public static final String KAFKA_HEADER_FOR_TYPE

See Also:

Constant Field Values

KAFKA_HEADER_FOR_SOURCE

public static final String KAFKA_HEADER_FOR_SOURCE

See Also:

Constant Field Values

KAFKA_HEADER_FOR_ID

public static final String KAFKA_HEADER_FOR_ID

See Also:

Constant Field Values

KAFKA_HEADER_FOR_SCHEMA

public static final String KAFKA_HEADER_FOR_SCHEMA

See Also:

Constant Field Values

KAFKA_HEADER_FOR_CONTENT_TYPE

public static final String KAFKA_HEADER_FOR_CONTENT_TYPE

See Also:

Constant Field Values

KAFKA_HEADER_FOR_SUBJECT

public static final String KAFKA_HEADER_FOR_SUBJECT

See Also:

Constant Field Values

KAFKA_HEADER_FOR_TIME

public static final String KAFKA_HEADER_FOR_TIME

See Also:

Constant Field Values

RFC3339_DATE_FORMAT

public static final DateTimeFormatter RFC3339_DATE_FORMAT

Method Detail

createFromStructuredCloudEvent

public static <T,K> IncomingKafkaCloudEventMetadata<K,T> createFromStructuredCloudEvent(org.apache.kafka.clients.consumer.ConsumerRecord<K,T> record)

createFromBinaryCloudEvent

public static <T,K> IncomingKafkaCloudEventMetadata<K,T> createFromBinaryCloudEvent(org.apache.kafka.clients.consumer.ConsumerRecord<?,T> record)

createBinaryRecord

public static org.apache.kafka.clients.producer.ProducerRecord<?,?> createBinaryRecord(Message<?> message,
                                                                                       String topic,
                                                                                       OutgoingKafkaRecordMetadata<?> metadata,
                                                                                       OutgoingCloudEventMetadata<?> ceMetadata,
                                                                                       KafkaConnectorOutgoingConfiguration configuration)

createStructuredRecord

public static org.apache.kafka.clients.producer.ProducerRecord<?,?> createStructuredRecord(Message<?> message,
                                                                                           String topic,
                                                                                           OutgoingKafkaRecordMetadata<?> metadata,
                                                                                           OutgoingCloudEventMetadata<?> ceMetadata,
                                                                                           KafkaConnectorOutgoingConfiguration configuration)

getCloudEventMode

public static KafkaCloudEventHelper.CloudEventMode getCloudEventMode(org.apache.kafka.clients.consumer.ConsumerRecord<?,?> record)