K - the type of the keyT - the type of the valueinstead@Deprecated public interface KafkaMessage<K,T> extends Message<T>, KafkaRecord<K,T>
| Modifier and Type | Method and Description |
|---|---|
static <K,T> OutgoingKafkaRecord<K,T> |
of(K key,
T value)
Deprecated.
Creates a new outgoing kafka message.
|
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.
|
from, getHeaders, getKey, getPartition, getTimestamp, getTopicack, addMetadata, getAck, getMetadata, getMetadata, getNack, getPayload, nack, nack, of, of, of, unwrap, withAck, withMetadata, withMetadata, withNack, withPayloadstatic <K,T> OutgoingKafkaRecord<K,T> of(K key, T value)
static <K,T> OutgoingKafkaRecord<K,T> of(String topic, K key, T value)
of in interface KafkaRecord<K,T>of in interface Message<T>K - the type of the keyT - the type of the valuetopic - the topic, must not be nullkey - the key, can be nullvalue - the value / payload, must not be nullstatic <K,T> OutgoingKafkaRecord<K,T> of(String topic, K key, T value, Instant timestamp, int partition)
of in interface KafkaRecord<K,T>K - the type of the keyT - the type of the valuetopic - the topic, must not be nullkey - the key, can be nullvalue - the value / payload, must not be nulltimestamp - the timestamp, can be null to indicate no timestamppartition - the partition, can be -1 to indicate no partitionCopyright © 2018–2021 SmallRye. All rights reserved.