org.seedstack.kafka

Annotation Type KafkaListener

@Documented
 @Retention(value=RUNTIME)
 @Target(value=TYPE)
 @Inherited
public @interface KafkaListener

By annotating a class implementing StreamBuilder or ConsumerListener with this annotation, the specified topics will be automatically subscribed to. The Kafka consumer will be automatically started and stopped. If an exception is rethrown by the listener, the Kafka client will be stopped gracefully. A retry will be scheduled after the specified retry delay.

Required Element Summary

Required Elements

Modifier and Type	Required Element and Description
String	value

Optional Element Summary

Optional Elements

Modifier and Type	Optional Element and Description
int	retryDelay
String	topicPattern Defines the regular expression pattern of the topic(s) to subscribe to.
String[]	topics

Element Detail

value

public abstract String value

Returns:

the name of the configured client (stream or consumer) to listen to.

topicPattern

public abstract String topicPattern

Defines the regular expression pattern of the topic(s) to subscribe to. Configuration macros can be used.

Returns:

the pattern of topics to subscribe (exclusive with topics()).

Default:

""

topics

public abstract String[] topics

Returns:

the array of topics to subscribe. Configuration macros can be used.

Default:

{}

retryDelay

public abstract int retryDelay

Returns:

the delay in milliseconds to observe after a failure and before retrying.

Default:

30000