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

BeforeKafkaStreamStart

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