Package io.micronaut.configuration.kafka.event

Class KafkaConsumerStartedPollingEvent

java.lang.Object

java.util.EventObject

io.micronaut.context.event.ApplicationEvent

io.micronaut.configuration.kafka.event.AbstractKafkaApplicationEvent<Consumer>

io.micronaut.configuration.kafka.event.KafkaConsumerStartedPollingEvent

All Implemented Interfaces:

Serializable

public final class KafkaConsumerStartedPollingEvent
extends AbstractKafkaApplicationEvent<Consumer>

An event fired after a Kafka Consumer executes the first polling.

Since:

5.1.0

Author:

Jorge F. Sanchez

See Also:

• Serialized Form

Field Summary

Fields inherited from class java.util.EventObject

source

Constructor Summary

Constructors

Constructor	Description
KafkaConsumerStartedPollingEvent(Consumer consumer)	Constructs an event with a given Consumer source.

Method Summary

Methods inherited from class io.micronaut.configuration.kafka.event.AbstractKafkaApplicationEvent

getSource

Methods inherited from class java.util.EventObject

toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Details

KafkaConsumerStartedPollingEvent

public KafkaConsumerStartedPollingEvent(Consumer consumer)

Constructs an event with a given Consumer source.

Parameters:

consumer - The Consumer on which the Event initially occurred.

Throws:

IllegalArgumentException - if source is null.