Interface IConfluentAdminClientFactory

Namespace

Silverback.Messaging.Broker.Kafka

Assembly

Silverback.Integration.Kafka.dll

The factory used to create Confluent.Kafka.IAdminClient instances.

public interface IConfluentAdminClientFactory

Extension Methods

ConfluentAdminClientFactoryExtensions.GetClient(IConfluentAdminClientFactory, KafkaClientConfiguration)

ConfluentAdminClientFactoryExtensions.GetClient(IConfluentAdminClientFactory, KafkaConsumerConfiguration)

ConfluentAdminClientFactoryExtensions.GetClient(IConfluentAdminClientFactory, KafkaProducerConfiguration)

ConfluentAdminClientFactoryExtensions.GetClient(IConfluentAdminClientFactory, Action<KafkaClientConfigurationBuilder>)

Methods

GetClient(AdminClientConfig)

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

IAdminClient GetClient(AdminClientConfig config)

Parameters

config AdminClientConfig

The client configuration.

Returns

IAdminClient

The Confluent.Kafka.IAdminClient.