Package io.micronaut.configuration.kafka.health

Class DefaultNetworkClientCreator

java.lang.Object

io.micronaut.configuration.kafka.health.DefaultNetworkClientCreator

All Implemented Interfaces:

NetworkClientCreator

@Singleton
public class DefaultNetworkClientCreator
extends Object
implements NetworkClientCreator

Default implementation of NetworkClientCreator. Based on KafkaAdminClient createInternal method.

Since:

5.1.0

Constructor Summary

Constructors

Constructor	Description
DefaultNetworkClientCreator(KafkaDefaultConfiguration defaultConfiguration)

Method Summary

Modifier and Type	Method	Description
@NonNull org.apache.kafka.clients.NetworkClient	create(@NonNull ClusterResourceListener... listeners)

Methods inherited from class java.lang.Object

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

Constructor Details

DefaultNetworkClientCreator

public DefaultNetworkClientCreator(KafkaDefaultConfiguration defaultConfiguration)

Method Details

create

@NonNull
public @NonNull org.apache.kafka.clients.NetworkClient create(@NonNull
 @NonNull ClusterResourceListener... listeners)

Specified by:

create in interface NetworkClientCreator

Parameters:

listeners - Cluster Resource Listeners

Returns:

A Kafka Network Client