Package io.micronaut.configuration.kafka

Class KafkaMessage<K,V>

java.lang.Object

io.micronaut.configuration.kafka.KafkaMessage<K,V>

Type Parameters:

K - The key type

V - The value type

public final class KafkaMessage<K,V>
extends Object

Message payload representation.

Since:

4.1.0

Author:

Denis Stepanov

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	KafkaMessage.Builder<K,V>	The message builder.

Constructor Summary

Constructors

Constructor	Description
KafkaMessage(@Nullable String topic, K key, V body, @Nullable Integer partition, @Nullable Long timestamp, @Nullable Map<String,Object> headers)	The default constructor.

Method Summary

Modifier and Type	Method	Description
V	getBody()
@Nullable Map<String,Object>	getHeaders()
K	getKey()
@Nullable Integer	getPartition()
@Nullable Long	getTimestamp()
@Nullable String	getTopic()

Methods inherited from class java.lang.Object

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

Constructor Details

KafkaMessage

public KafkaMessage(@Nullable
 @Nullable String topic,
 @Nullable
 K key,
 @Nullable
 V body,
 @Nullable
 @Nullable Integer partition,
 @Nullable
 @Nullable Long timestamp,
 @Nullable
 @Nullable Map<String,Object> headers)

The default constructor.

Parameters:

topic - The topic

key - The key

body - The body

partition - The partition

timestamp - The timestamp

headers - The headers

Method Details

getTopic

@Nullable
public @Nullable String getTopic()

getKey

@Nullable
public K getKey()

getBody

@Nullable
public V getBody()

getPartition

@Nullable
public @Nullable Integer getPartition()

getTimestamp

@Nullable
public @Nullable Long getTimestamp()

getHeaders

@Nullable
public @Nullable Map<String,Object> getHeaders()