Class ConfluentAdminClientFactoryExtensions

Adds some convenience methods to the IConfluentAdminClientFactory interface.

Inheritance

object

ConfluentAdminClientFactoryExtensions

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 static class ConfluentAdminClientFactoryExtensions

Methods

GetClient(IConfluentAdminClientFactory, KafkaClientConfiguration)

Creates a new Confluent.Kafka.IAdminClient instance using the specified configuration.

Declaration

public static IAdminClient GetClient(this IConfluentAdminClientFactory factory, KafkaClientConfiguration configuration)

Parameters

Type	Name	Description
IConfluentAdminClientFactory	factory	The IConfluentAdminClientFactory.
KafkaClientConfiguration	configuration	The configuration.

Returns

Type	Description
IAdminClient	The Confluent.Kafka.IAdminClient.

GetClient(IConfluentAdminClientFactory, KafkaConsumerConfiguration)

Creates a new Confluent.Kafka.IAdminClient instance using the specified configuration.

Declaration

public static IAdminClient GetClient(this IConfluentAdminClientFactory factory, KafkaConsumerConfiguration configuration)

Parameters

Type	Name	Description
IConfluentAdminClientFactory	factory	The IConfluentAdminClientFactory.
KafkaConsumerConfiguration	configuration	The configuration.

Returns

Type	Description
IAdminClient	The Confluent.Kafka.IAdminClient.

GetClient(IConfluentAdminClientFactory, KafkaProducerConfiguration)

Creates a new Confluent.Kafka.IAdminClient instance using the specified configuration.

Declaration

public static IAdminClient GetClient(this IConfluentAdminClientFactory factory, KafkaProducerConfiguration configuration)

Parameters

Type	Name	Description
IConfluentAdminClientFactory	factory	The IConfluentAdminClientFactory.
KafkaProducerConfiguration	configuration	The configuration.

Returns

Type	Description
IAdminClient	The Confluent.Kafka.IAdminClient.

GetClient(IConfluentAdminClientFactory, Action<KafkaClientConfigurationBuilder>)

Creates a new Confluent.Kafka.IAdminClient instance using the specified configuration.

Declaration

public static IAdminClient GetClient(this IConfluentAdminClientFactory factory, Action<KafkaClientConfigurationBuilder> builderAction)

Parameters

Type	Name	Description
IConfluentAdminClientFactory	factory	The IConfluentAdminClientFactory.
Action<KafkaClientConfigurationBuilder>	builderAction	An Action<T> that takes a KafkaClientConfigurationBuilder and configures it.

Returns

Type	Description
IAdminClient	The Confluent.Kafka.IAdminClient.