io.micronaut.configuration.kafka.streams

Class KafkaStreamsFactory

java.lang.Object

io.micronaut.configuration.kafka.streams.KafkaStreamsFactory

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable

@Factory
public class KafkaStreamsFactory
extends java.lang.Object
implements java.io.Closeable

A factory that constructs the KafkaStreams bean.

Since:

1.0

Author:

Graeme Rocher

Constructor Summary

Constructors

Constructor and Description
KafkaStreamsFactory(io.micronaut.context.event.ApplicationEventPublisher eventPublisher) Default constructor.

Method Summary

Modifier and Type	Method and Description
void	close()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

KafkaStreamsFactory

public KafkaStreamsFactory(io.micronaut.context.event.ApplicationEventPublisher eventPublisher)

Default constructor.

Parameters:

eventPublisher - The event publisher

Method Detail

close

@PreDestroy
public void close()

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable