Package io.smallrye.reactive.messaging.kafka

Interface KafkaMessage<K,T>

Type Parameters:

K - the type of the key

T - the type of the value

All Superinterfaces:

KafkaRecord<K,T>, Message<T>

@Deprecated
public interface KafkaMessage<K,T>
extends Message<T>, KafkaRecord<K,T>

Deprecated.

Use instead

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>	of(String topic, K key, T value)	Deprecated. Creates a new outgoing kafka message.
static <K,T> OutgoingKafkaRecord<K,T>	of(String topic, K key, T value, Instant timestamp, int partition)	Deprecated. Creates a new outgoing kafka message.
static <K,T> OutgoingKafkaRecord<K,T>	of(K key, T value)	Deprecated. Creates a new outgoing kafka message.

Methods inherited from interface io.smallrye.reactive.messaging.kafka.KafkaRecord

getHeaders, getKey, getPartition, getTimestamp, getTopic

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

of

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

Deprecated.

Creates a new outgoing kafka message.

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 message

of

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

Deprecated.

Creates a new outgoing kafka message.

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 message

of

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

Deprecated.

Creates a new outgoing kafka message.

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 message