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(String topic, K key, V body, Integer partition, Long timestamp, Map<String,Object> headers)	The default constructor.

Method Summary

Modifier and Type	Method	Description
V	getBody()
Map<String,Object>	getHeaders()
K	getKey()
Integer	getPartition()
Long	getTimestamp()
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
 String topic,
 @Nullable
 K key,
 @Nullable
 V body,
 @Nullable
 Integer partition,
 @Nullable
 Long timestamp,
 @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 String getTopic()

getKey

@Nullable
public K getKey()

getBody

@Nullable
public V getBody()

getPartition

@Nullable
public Integer getPartition()

getTimestamp

@Nullable
public Long getTimestamp()

getHeaders

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