Class ConfluentAdminClientFactory

Wraps the Confluent.Kafka.AdminClientBuilder.

Inheritance

object

ConfluentAdminClientFactory

Implements

IConfluentAdminClientFactory

Inherited Members

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Namespace: Silverback.Messaging.Broker.Kafka

Assembly: Silverback.Integration.Kafka.dll

Syntax

public class ConfluentAdminClientFactory : IConfluentAdminClientFactory

Constructors

ConfluentAdminClientFactory(ISilverbackLogger<ConfluentAdminClientFactory>)

Initializes a new instance of the ConfluentAdminClientFactory class.

Declaration

public ConfluentAdminClientFactory(ISilverbackLogger<ConfluentAdminClientFactory> logger)

Parameters

Type	Name	Description
ISilverbackLogger<ConfluentAdminClientFactory>	logger	The ISilverbackLogger.

Methods

GetClient(ClientConfig)

Returns an Confluent.Kafka.IAdminClient instance for the specified configuration.

Declaration

public IAdminClient GetClient(ClientConfig config)

Parameters

Type	Name	Description
ClientConfig	config	The client configuration.

Returns

Type	Description
IAdminClient	The Confluent.Kafka.IAdminClient.

Implements

IConfluentAdminClientFactory

Extension Methods

ConfluentAdminClientFactoryExtensions.GetClient(IConfluentAdminClientFactory, KafkaClientConfiguration)

ConfluentAdminClientFactoryExtensions.GetClient(IConfluentAdminClientFactory, KafkaConsumerConfiguration)

ConfluentAdminClientFactoryExtensions.GetClient(IConfluentAdminClientFactory, KafkaProducerConfiguration)

ConfluentAdminClientFactoryExtensions.GetClient(IConfluentAdminClientFactory, Action<KafkaClientConfigurationBuilder>)