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

The message builder.

Constructor Summary

Constructors

Constructor and Description
Builder()

Method Summary

Modifier and Type	Method and Description
KafkaMessage.Builder<K,V>	body(V body)
KafkaMessage<K,V>	build()
KafkaMessage.Builder<K,V>	header(java.util.Map<java.lang.String,java.lang.Object> headers)
KafkaMessage.Builder<K,V>	key(K key)
KafkaMessage.Builder<K,V>	partition(java.lang.Integer partition)
KafkaMessage.Builder<K,V>	timestamp(java.lang.Long timestamp)
KafkaMessage.Builder<K,V>	topic(java.lang.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 Detail

Builder

public Builder()

Method Detail

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
                                                java.lang.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
                                                 java.util.Map<java.lang.String,java.lang.Object> headers)

partition

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

timestamp

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

build

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