Package io.micronaut.configuration.kafka.event

Class KafkaConsumerSubscribedEvent

java.lang.Object

java.util.EventObject

io.micronaut.context.event.ApplicationEvent

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

io.micronaut.configuration.kafka.event.KafkaConsumerSubscribedEvent

All Implemented Interfaces:

Serializable

public final class KafkaConsumerSubscribedEvent
extends AbstractKafkaApplicationEvent<Consumer>

An event fired after a Kafka Consumer subscribes to a set of Kafka topics.

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
KafkaConsumerSubscribedEvent(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

KafkaConsumerSubscribedEvent

public KafkaConsumerSubscribedEvent(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.