io.smallrye.reactive.messaging.kafka

Class IncomingKafkaRecord<K,T>

java.lang.Object

io.smallrye.reactive.messaging.kafka.IncomingKafkaRecord<K,T>

All Implemented Interfaces:

KafkaRecord<K,T>, Message<T>

public class IncomingKafkaRecord<K,T>
extends Object
implements KafkaRecord<K,T>

Constructor Summary

Constructors

Constructor and Description
IncomingKafkaRecord(io.vertx.mutiny.kafka.client.consumer.KafkaConsumer<K,T> consumer, io.vertx.mutiny.kafka.client.consumer.KafkaConsumerRecord<K,T> record)

Method Summary

Modifier and Type	Method and Description
CompletionStage<Void>	ack() Acknowledge this message.
Supplier<CompletionStage<Void>>	getAck()
org.apache.kafka.common.header.Headers	getHeaders()
K	getKey()
Metadata	getMetadata()
long	getOffset()
int	getPartition()
T	getPayload()
Instant	getTimestamp()
String	getTopic()

Methods inherited from class java.lang.Object

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

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

of, of, of

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

addMetadata, getMetadata, of, unwrap, withAck, withMetadata, withMetadata, withPayload

Constructor Detail

IncomingKafkaRecord

public IncomingKafkaRecord(io.vertx.mutiny.kafka.client.consumer.KafkaConsumer<K,T> consumer,
                           io.vertx.mutiny.kafka.client.consumer.KafkaConsumerRecord<K,T> record)

Method Detail

getPayload

public T getPayload()

Specified by:

getPayload in interface Message<T>

Returns:

The payload for this message.

getKey

public K getKey()

Specified by:

getKey in interface KafkaRecord<K,T>

getTopic

public String getTopic()

Specified by:

getTopic in interface KafkaRecord<K,T>

getPartition

public int getPartition()

Specified by:

getPartition in interface KafkaRecord<K,T>

getTimestamp

public Instant getTimestamp()

Specified by:

getTimestamp in interface KafkaRecord<K,T>

getHeaders

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

Specified by:

getHeaders in interface KafkaRecord<K,T>

getOffset

public long getOffset()

getMetadata

public Metadata getMetadata()

Specified by:

getMetadata in interface Message<T>

Returns:

The set of metadata attached to this message, potentially empty.

getAck

public Supplier<CompletionStage<Void>> getAck()

Specified by:

getAck in interface Message<T>

Returns:

the supplier used to retrieve the acknowledgement CompletionStage.

ack

public CompletionStage<Void> ack()

Description copied from interface: Message

Acknowledge this message.

Specified by:

ack in interface Message<T>

Returns:

a completion stage completed when the message is acknowledged. If the acknowledgement fails, the completion stage propagates the failure.