Package io.smallrye.reactive.messaging.kafka

Interface KafkaRecord<K,T>

All Superinterfaces:

Message<T>

All Known Subinterfaces:

KafkaMessage<K,T>

All Known Implementing Classes:

IncomingKafkaRecord, OutgoingKafkaRecord

public interface KafkaRecord<K,T>
extends Message<T>

Field Summary

Fields inherited from interface org.eclipse.microprofile.reactive.messaging.Message

LOGGER

Method Summary

Modifier and Type	Method	Description
static <K,T> OutgoingKafkaRecord<K,T>	from(Message<T> message)
org.apache.kafka.common.header.Headers	getHeaders()
K	getKey()
int	getPartition()
Instant	getTimestamp()
String	getTopic()
static <K,T> OutgoingKafkaRecord<K,T>	of(String topic, K key, T value)	Creates a new outgoing Kafka record.
static <K,T> OutgoingKafkaRecord<K,T>	of(String topic, K key, T value, Instant timestamp, int partition)	Creates a new outgoing Kafka record.
static <K,T> OutgoingKafkaRecord<K,T>	of(K key, T value)	Creates a new outgoing Kafka record.

Methods inherited from interface org.eclipse.microprofile.reactive.messaging.Message

ack, addMetadata, getAck, getMetadata, getMetadata, getNack, getPayload, nack, unwrap, withAck, withMetadata, withMetadata, withNack, withPayload

Method Detail

from

static <K,T> OutgoingKafkaRecord<K,T> from(Message<T> message)

of

static <K,T> OutgoingKafkaRecord<K,T> of(K key,
                                                     T value)

Creates a new outgoing Kafka record.

Type Parameters:

K - the type of the key

T - the type of the value

Parameters:

key - the key, can be null

value - the value / payload, must not be null

Returns:

the new outgoing Kafka record

of

static <K,T> OutgoingKafkaRecord<K,T> of(String topic,
                                                     K key,
                                                     T value)

Creates a new outgoing Kafka record.

Type Parameters:

K - the type of the key

T - the type of the value

Parameters:

topic - the topic, must not be null

key - the key, can be null

value - the value / payload, must not be null

Returns:

the new outgoing Kafka record

of

static <K,T> OutgoingKafkaRecord<K,T> of(String topic,
                                                     K key,
                                                     T value,
                                                     Instant timestamp,
                                                     int partition)

Creates a new outgoing Kafka record.

Type Parameters:

K - the type of the key

T - the type of the value

Parameters:

topic - the topic, must not be null

key - the key, can be null

value - the value / payload, must not be null

timestamp - the timestamp, can be null to indicate no timestamp

partition - the partition, can be -1 to indicate no partition

Returns:

the new outgoing Kafka record

getKey

K getKey()

getTopic

String getTopic()

getPartition

int getPartition()

getTimestamp

Instant getTimestamp()

getHeaders

org.apache.kafka.common.header.Headers getHeaders()