Package 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:

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