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

Class AfterKafkaStreamsStart

java.lang.Object

java.util.EventObject

io.micronaut.context.event.ApplicationEvent

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, 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