Class ConfluentAdminClientFactoryExtensions

Namespace

Silverback.Messaging.Broker.Kafka

Assembly

Silverback.Integration.Kafka.dll

Adds some convenience methods to the IConfluentAdminClientFactory interface.

public static class ConfluentAdminClientFactoryExtensions

Inheritance

object

ConfluentAdminClientFactoryExtensions

Inherited Members

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Methods

GetClient(IConfluentAdminClientFactory, KafkaClientConfiguration)

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

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

Parameters

factory IConfluentAdminClientFactory

The IConfluentAdminClientFactory.

configuration KafkaClientConfiguration

The configuration.

Returns

IAdminClient

The Confluent.Kafka.IAdminClient.

GetClient(IConfluentAdminClientFactory, KafkaConsumerConfiguration)

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

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

Parameters

factory IConfluentAdminClientFactory

The IConfluentAdminClientFactory.

configuration KafkaConsumerConfiguration

The configuration.

Returns

IAdminClient

The Confluent.Kafka.IAdminClient.

GetClient(IConfluentAdminClientFactory, KafkaProducerConfiguration)

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

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

Parameters

factory IConfluentAdminClientFactory

The IConfluentAdminClientFactory.

configuration KafkaProducerConfiguration

The configuration.

Returns

IAdminClient

The Confluent.Kafka.IAdminClient.

GetClient(IConfluentAdminClientFactory, Action<KafkaClientConfigurationBuilder>)

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

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

Parameters

factory IConfluentAdminClientFactory

The IConfluentAdminClientFactory.

builderAction Action<KafkaClientConfigurationBuilder>

An Action<T> that takes a KafkaClientConfigurationBuilder and configures it.

Returns

IAdminClient

The Confluent.Kafka.IAdminClient.