Package io.micronaut.configuration.kafka

Class KafkaMessage.Builder<K,V>

java.lang.Object

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

Type Parameters:

K - The key type

V - The value type

Enclosing class:

KafkaMessage<K,V>

public static final class KafkaMessage.Builder<K,V>
extends Object

The message builder.

Constructor Summary

Constructors

Constructor	Description
Builder()

Method Summary

Modifier and Type	Method	Description
KafkaMessage.Builder<K,V>	body(V body)
KafkaMessage<K,V>	build()
KafkaMessage.Builder<K,V>	header(Map<String,Object> headers)
KafkaMessage.Builder<K,V>	key(K key)
KafkaMessage.Builder<K,V>	partition(Integer partition)
KafkaMessage.Builder<K,V>	timestamp(Long timestamp)
KafkaMessage.Builder<K,V>	topic(String topic)
static <T, F> KafkaMessage.Builder<T,F>	withBody(F body)
static <T, F> KafkaMessage.Builder<T,F>	withoutBody()

Methods inherited from class java.lang.Object

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

Constructor Details

Builder

public Builder()

Method Details

withBody

@NonNull
public static <T,
F> KafkaMessage.Builder<T,F> withBody(@Nullable
 F body)

withoutBody

@NonNull
public static <T,
F> KafkaMessage.Builder<T,F> withoutBody()

topic

@NonNull
public KafkaMessage.Builder<K,V> topic(@Nullable
 String topic)

key

@NonNull
public KafkaMessage.Builder<K,V> key(@Nullable
 K key)

body

@NonNull
public KafkaMessage.Builder<K,V> body(@Nullable
 V body)

header

@NonNull
public KafkaMessage.Builder<K,V> header(@Nullable
 Map<String,Object> headers)

partition

@NonNull
public KafkaMessage.Builder<K,V> partition(@Nullable
 Integer partition)

timestamp

@NonNull
public KafkaMessage.Builder<K,V> timestamp(@Nullable
 Long timestamp)

build

@NonNull
public KafkaMessage<K,V> build()