io.micronaut.configuration.kafka.streams.event

Class BeforeKafkaStreamStart

java.lang.Object

java.util.EventObject

io.micronaut.context.event.ApplicationEvent

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

io.micronaut.configuration.kafka.streams.event.BeforeKafkaStreamStart

All Implemented Interfaces:

java.io.Serializable

public class BeforeKafkaStreamStart
extends AbstractKafkaStreamsEvent

An event fired before a KafkaStreams object starts.

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

BeforeKafkaStreamStart

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

Default constructor.

Parameters:

kafkaStreams - The kafka streams object

streams - The kstreams

Method Detail

getStreams

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

Returns:

The streams