Class ConfluentAdminClientFactory

Namespace

Silverback.Messaging.Broker.Kafka

Assembly

Silverback.Integration.Kafka.dll

Wraps the Confluent.Kafka.AdminClientBuilder.

public class ConfluentAdminClientFactory : IConfluentAdminClientFactory

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()

Extension Methods

ConfluentAdminClientFactoryExtensions.GetClient(IConfluentAdminClientFactory, KafkaClientConfiguration)

ConfluentAdminClientFactoryExtensions.GetClient(IConfluentAdminClientFactory, KafkaConsumerConfiguration)

ConfluentAdminClientFactoryExtensions.GetClient(IConfluentAdminClientFactory, KafkaProducerConfiguration)

ConfluentAdminClientFactoryExtensions.GetClient(IConfluentAdminClientFactory, Action<KafkaClientConfigurationBuilder>)

Constructors

ConfluentAdminClientFactory(ISilverbackLogger<ConfluentAdminClientFactory>)

Initializes a new instance of the ConfluentAdminClientFactory class.

public ConfluentAdminClientFactory(ISilverbackLogger<ConfluentAdminClientFactory> logger)

Parameters

logger ISilverbackLogger<ConfluentAdminClientFactory>

The ISilverbackLogger.

Methods

GetClient(AdminClientConfig)

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

public IAdminClient GetClient(AdminClientConfig config)

Parameters

config AdminClientConfig

The client configuration.

Returns

IAdminClient

The Confluent.Kafka.IAdminClient.