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:

java.io.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 and Description
AfterKafkaStreamsStart(KafkaStreams kafkaStreams, KStream<?,?>[] streams) Default constructor.

Method Summary

Modifier and Type	Method and 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 Detail

AfterKafkaStreamsStart

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

Default constructor.

Parameters:

kafkaStreams - The kafka streams object

streams - The kstreams

Method Detail

getStreams

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

Returns:

The streams