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
@NonNull KafkaMessage.Builder<K,V>	body(@Nullable V body)
@NonNull KafkaMessage<K,V>	build()
@NonNull KafkaMessage.Builder<K,V>	header(@Nullable Map<String,Object> headers)
@NonNull KafkaMessage.Builder<K,V>	key(@Nullable K key)
@NonNull KafkaMessage.Builder<K,V>	partition(@Nullable Integer partition)
@NonNull KafkaMessage.Builder<K,V>	timestamp(@Nullable Long timestamp)
@NonNull KafkaMessage.Builder<K,V>	topic(@Nullable String topic)
static <T, F> @NonNull KafkaMessage.Builder<T,F>	withBody(@Nullable F body)
static <T, F> @NonNull 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

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

withoutBody

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

topic

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

key

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

body

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

header

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

partition

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

timestamp

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

build

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