io.micronaut.configuration.kafka.streams.registry

Class KafkaStreamRegistryFactory

java.lang.Object

io.micronaut.configuration.kafka.streams.registry.KafkaStreamRegistryFactory

@Factory
public class KafkaStreamRegistryFactory
extends Object

A factory that constructs a KafkaStreamsRegistry and QueryableStoreRegistry beans.

Since:

1.1

Author:

Christian Oestreich

Constructor Summary

Constructors

Constructor and Description
KafkaStreamRegistryFactory()

Method Summary

Modifier and Type	Method and Description
io.micronaut.configuration.kafka.streams.registry.KafkaStreamsRegistry	kafkaStreamsRegistry(Set<KafkaStreams> kafkaStreamsList) Exposes the KafkaStreamsRegistry as a bean.
QueryableStoreRegistry	queryableStoreTypeRegistry(io.micronaut.configuration.kafka.streams.registry.KafkaStreamsRegistry kafkaStreamsRegistry) Exposes the QueryableStoreRegistry as a bean.

Methods inherited from class java.lang.Object

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

Constructor Detail

KafkaStreamRegistryFactory

public KafkaStreamRegistryFactory()

Method Detail

kafkaStreamsRegistry

@Bean
public io.micronaut.configuration.kafka.streams.registry.KafkaStreamsRegistry kafkaStreamsRegistry(Set<KafkaStreams> kafkaStreamsList)

Exposes the KafkaStreamsRegistry as a bean.

Parameters:

kafkaStreamsList - The list of registered streams

Returns:

The kafka streams registry

queryableStoreTypeRegistry

@Bean
public QueryableStoreRegistry queryableStoreTypeRegistry(io.micronaut.configuration.kafka.streams.registry.KafkaStreamsRegistry kafkaStreamsRegistry)

Exposes the QueryableStoreRegistry as a bean.

Parameters:

kafkaStreamsRegistry - The bean that contains the list of registered streams

Returns:

The queryable store registry