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(V body)
@NonNull KafkaMessage<K,V>	build()
@NonNull KafkaMessage.Builder<K,V>	header(@Nullable Map<String,Object> headers)
@NonNull KafkaMessage.Builder<K,V>	key(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(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

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

withoutBody

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

topic

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

key

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

body

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

header

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

partition

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

timestamp

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

build

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