io.micronaut.configuration.kafka.scope

Class KafkaClientScope

java.lang.Object

io.micronaut.configuration.kafka.scope.KafkaClientScope

All Implemented Interfaces:

KafkaProducerRegistry, io.micronaut.context.LifeCycle<KafkaClientScope>, io.micronaut.context.scope.CustomScope<KafkaClient>, java.io.Closeable, java.lang.AutoCloseable

@Singleton
public class KafkaClientScope
extends java.lang.Object
implements io.micronaut.context.scope.CustomScope<KafkaClient>, io.micronaut.context.LifeCycle<KafkaClientScope>, KafkaProducerRegistry

A scope implementation for injecting KafkaProducer instances.

Since:

1.0

Author:

Graeme Rocher

Constructor Summary

Constructors

Constructor and Description
KafkaClientScope(io.micronaut.context.BeanContext beanContext, SerdeRegistry serdeRegistry) Constructs a new client scope.

Method Summary

Modifier and Type	Method and Description
java.lang.Class<KafkaClient>	annotationType()
<T> T	get(io.micronaut.context.BeanResolutionContext resolutionContext, io.micronaut.inject.BeanDefinition<T> beanDefinition, io.micronaut.inject.BeanIdentifier identifier, javax.inject.Provider<T> provider)
<K,V> org.apache.kafka.clients.producer.KafkaProducer	getProducer(java.lang.String id, io.micronaut.core.type.Argument<K> keyType, io.micronaut.core.type.Argument<V> valueType) Returns a managed Producer.
boolean	isRunning()
<T> java.util.Optional<T>	remove(io.micronaut.inject.BeanIdentifier identifier)
KafkaClientScope	stop()

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.micronaut.context.scope.CustomScope

findBeanRegistration

Methods inherited from interface io.micronaut.context.LifeCycle

close, refresh, start

Constructor Detail

KafkaClientScope

public KafkaClientScope(io.micronaut.context.BeanContext beanContext,
                        SerdeRegistry serdeRegistry)

Constructs a new client scope.

Parameters:

beanContext - The bean context

serdeRegistry - The serde registry

Method Detail

isRunning

public boolean isRunning()

Specified by:

isRunning in interface io.micronaut.context.LifeCycle<KafkaClientScope>

annotationType

public java.lang.Class<KafkaClient> annotationType()

Specified by:

annotationType in interface io.micronaut.context.scope.CustomScope<KafkaClient>

get

public <T> T get(io.micronaut.context.BeanResolutionContext resolutionContext,
                 io.micronaut.inject.BeanDefinition<T> beanDefinition,
                 io.micronaut.inject.BeanIdentifier identifier,
                 javax.inject.Provider<T> provider)

Specified by:

get in interface io.micronaut.context.scope.CustomScope<KafkaClient>

getProducer

@Nonnull
public <K,V> org.apache.kafka.clients.producer.KafkaProducer getProducer(java.lang.String id,
                                                                                  io.micronaut.core.type.Argument<K> keyType,
                                                                                  io.micronaut.core.type.Argument<V> valueType)

Description copied from interface: KafkaProducerRegistry

Returns a managed Producer.

Specified by:

getProducer in interface KafkaProducerRegistry

Type Parameters:

K - The key generic type

V - The value generic type

Parameters:

id - The id of the producer.

keyType - The key type

valueType - The value type

Returns:

The producer

stop

public KafkaClientScope stop()

Specified by:

stop in interface io.micronaut.context.LifeCycle<KafkaClientScope>

remove

public <T> java.util.Optional<T> remove(io.micronaut.inject.BeanIdentifier identifier)

Specified by:

remove in interface io.micronaut.context.scope.CustomScope<KafkaClient>