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 java.lang.Object

Message payload representation.

Since:

4.1.0

Author:

Denis Stepanov

Nested Class Summary

Nested Classes

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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
V	getBody()
java.util.Map<java.lang.String,java.lang.Object>	getHeaders()
K	getKey()
java.lang.Integer	getPartition()
java.lang.Long	getTimestamp()
java.lang.String	getTopic()

Methods inherited from class java.lang.Object

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

Constructor Detail

KafkaMessage

public KafkaMessage(@Nullable
                    java.lang.String topic,
                    @Nullable
                    K key,
                    @Nullable
                    V body,
                    @Nullable
                    java.lang.Integer partition,
                    @Nullable
                    java.lang.Long timestamp,
                    @Nullable
                    java.util.Map<java.lang.String,java.lang.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 Detail

getTopic

@Nullable
public java.lang.String getTopic()

getKey

@Nullable
public K getKey()

getBody

@Nullable
public V getBody()

getPartition

@Nullable
public java.lang.Integer getPartition()

getTimestamp

@Nullable
public java.lang.Long getTimestamp()

getHeaders

@Nullable
public java.util.Map<java.lang.String,java.lang.Object> getHeaders()