Package io.micronaut.configuration.kafka.streams.event

Class AfterKafkaStreamsStart

java.lang.Object

java.util.EventObject

io.micronaut.context.event.ApplicationEvent

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

io.micronaut.configuration.kafka.streams.event.AbstractKafkaStreamsEvent

io.micronaut.configuration.kafka.streams.event.AfterKafkaStreamsStart

All Implemented Interfaces:

Serializable

public class AfterKafkaStreamsStart
extends AbstractKafkaStreamsEvent

Event fired after the Kafka streams have started.

Since:

2.0.0

Author:

graemerocher

See Also:

• Serialized Form

Field Summary

Fields inherited from class java.util.EventObject

source

Constructor Summary

Constructors

Constructor	Description
AfterKafkaStreamsStart(KafkaStreams kafkaStreams, KStream<?,?>[] streams)	Default constructor.

Method Summary

Modifier and Type	Method	Description
KStream<?,?>[]	getStreams()

Methods inherited from class io.micronaut.configuration.kafka.streams.event.AbstractKafkaStreamsEvent

getKafkaStreams

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

AfterKafkaStreamsStart

public AfterKafkaStreamsStart(KafkaStreams kafkaStreams,
 KStream<?,?>[] streams)

Default constructor.

Parameters:

kafkaStreams - The kafka streams object

streams - The kstreams

Method Details

getStreams

public KStream<?,?>[] getStreams()

Returns:

The streams