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(org.apache.kafka.streams.KafkaStreams kafkaStreams, org.apache.kafka.streams.kstream.KStream<?,?>[] streams) Default constructor.

Method Summary

Modifier and Type	Method and Description
org.apache.kafka.streams.kstream.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(org.apache.kafka.streams.KafkaStreams kafkaStreams,
                              org.apache.kafka.streams.kstream.KStream<?,?>[] streams)

Default constructor.

Parameters:

kafkaStreams - The kafka streams object

streams - The kstreams

Method Detail

getStreams

public org.apache.kafka.streams.kstream.KStream<?,?>[] getStreams()

Returns:

The streams