io.micronaut.configuration.kafka.annotation

Annotation Type KafkaClient

@Documented
 @Retention(value=RUNTIME)
 @Scope
 @Introduction
 @Type(value=KafkaClientIntroductionAdvice.class)
 @Recoverable
 @Singleton
public @interface KafkaClient

An introduction advice that automatically implements interfaces and abstract classes and creates KafkaProducer instances.

Since:

1.0

Author:

Graeme Rocher

See Also:

KafkaClientIntroductionAdvice

Optional Element Summary

Optional Elements

Modifier and Type	Optional Element and Description
int	acks
boolean	batch By default when specifying an array or List the object will be serializes to a JSON array.
java.lang.String	id
java.lang.String	maxBlock The maximum duration to block synchronous send operations.
io.micronaut.context.annotation.Property[]	properties Additional properties to configure with for Consumer.
boolean	timestamp Whether to include timestamps in outgoing messages.
java.lang.String	value Same as id().

Element Detail

value

@AliasFor(member="id")
public abstract java.lang.String value

Same as id().

Returns:

The id of the client

Default:

""

id

@AliasFor(member="value")
public abstract java.lang.String id

Returns:

The id of the client

Default:

""

maxBlock

public abstract java.lang.String maxBlock

The maximum duration to block synchronous send operations.

Returns:

The timeout

Default:

""

timestamp

public abstract boolean timestamp

Whether to include timestamps in outgoing messages.

Returns:

True if time stamps should be included. Defaults to false.

Default:

false

batch

public abstract boolean batch

By default when specifying an array or List the object will be serializes to a JSON array. By specifying true this will instead send each record in the the array or list as an individual ProducerRecord.

Returns:

Whether to receive a batch of records or not

Default:

false

properties

public abstract io.micronaut.context.annotation.Property[] properties

Additional properties to configure with for Consumer.

Returns:

The properties

Default:

{}

acks

public abstract int acks

Returns:

The ack setting for the client, which impacts message delivery durability.

See Also:

ProducerConfig.ACKS_DOC, KafkaClient.Acknowledge

Default:

-2147483648