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

Class BeforeKafkaStreamStart

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

All Implemented Interfaces:

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

BeforeKafkaStreamStart

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

Default constructor.

Parameters:

kafkaStreams - The kafka streams object

streams - The kstreams

Method Details

getStreams

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

Returns:

The streams