Class ProducerConfigBuilder

Namespace

MASES.KNet.Producer

Assembly

MASES.KNet.dll

Builder for ProducerConfig

public class ProducerConfigBuilder : CommonClientConfigsBuilder<ProducerConfigBuilder>, INotifyPropertyChanged, IGenericSerDesFactory, IDisposable

Inheritance

object

GenericConfigBuilder<ProducerConfigBuilder>

CommonClientConfigsBuilder<ProducerConfigBuilder>

ProducerConfigBuilder

Implements

INotifyPropertyChanged

IGenericSerDesFactory

IDisposable

Inherited Members

CommonClientConfigsBuilder<ProducerConfigBuilder>.BootstrapServers

CommonClientConfigsBuilder<ProducerConfigBuilder>.WithBootstrapServers(string)

CommonClientConfigsBuilder<ProducerConfigBuilder>.ClientDnsLookup

CommonClientConfigsBuilder<ProducerConfigBuilder>.WithClientDnsLookup(string)

CommonClientConfigsBuilder<ProducerConfigBuilder>.MetadataMaxAge

CommonClientConfigsBuilder<ProducerConfigBuilder>.WithMetadataMaxAge(long)

CommonClientConfigsBuilder<ProducerConfigBuilder>.SendBuffer

CommonClientConfigsBuilder<ProducerConfigBuilder>.WithSendBuffer(int)

CommonClientConfigsBuilder<ProducerConfigBuilder>.ReceiveBuffer

CommonClientConfigsBuilder<ProducerConfigBuilder>.WithReceiveBuffer(int)

CommonClientConfigsBuilder<ProducerConfigBuilder>.ClientId

CommonClientConfigsBuilder<ProducerConfigBuilder>.WithClientId(string)

CommonClientConfigsBuilder<ProducerConfigBuilder>.ClientRack

CommonClientConfigsBuilder<ProducerConfigBuilder>.WithClientRack(string)

CommonClientConfigsBuilder<ProducerConfigBuilder>.ReconnectBackoffMs

CommonClientConfigsBuilder<ProducerConfigBuilder>.WithReconnectBackoffMs(long)

CommonClientConfigsBuilder<ProducerConfigBuilder>.ReconnectBackoffMaxMs

CommonClientConfigsBuilder<ProducerConfigBuilder>.WithReconnectBackoffMaxMs(long)

CommonClientConfigsBuilder<ProducerConfigBuilder>.Retries

CommonClientConfigsBuilder<ProducerConfigBuilder>.WithRetries(int)

CommonClientConfigsBuilder<ProducerConfigBuilder>.RetryBackoffMaxMs

CommonClientConfigsBuilder<ProducerConfigBuilder>.WithRetryBackoffMaxMs(long)

CommonClientConfigsBuilder<ProducerConfigBuilder>.RetryBackoffMs

CommonClientConfigsBuilder<ProducerConfigBuilder>.WithRetryBackoffMs(long)

CommonClientConfigsBuilder<ProducerConfigBuilder>.MetricSampleWindowMs

CommonClientConfigsBuilder<ProducerConfigBuilder>.WithMetricSampleWindowMs(long)

CommonClientConfigsBuilder<ProducerConfigBuilder>.MetricNumSample

CommonClientConfigsBuilder<ProducerConfigBuilder>.WithMetricNumSample(int)

CommonClientConfigsBuilder<ProducerConfigBuilder>.MetricRecordingLevel

CommonClientConfigsBuilder<ProducerConfigBuilder>.WithMetricRecordingLevel(Sensor.RecordingLevel)

CommonClientConfigsBuilder<ProducerConfigBuilder>.MetricReporterClasses

CommonClientConfigsBuilder<ProducerConfigBuilder>.WithMetricReporterClasses(List<Class>)

CommonClientConfigsBuilder<ProducerConfigBuilder>.SecurityProtocol

CommonClientConfigsBuilder<ProducerConfigBuilder>.WithSecurityProtocol(string)

CommonClientConfigsBuilder<ProducerConfigBuilder>.SocketConnectionSetupTimeoutMs

CommonClientConfigsBuilder<ProducerConfigBuilder>.WithSocketConnectionSetupTimeoutMs(long)

CommonClientConfigsBuilder<ProducerConfigBuilder>.SocketConnectionSetupTimeoutMaxMs

CommonClientConfigsBuilder<ProducerConfigBuilder>.WithSocketConnectionSetupTimeoutMaxMs(long)

CommonClientConfigsBuilder<ProducerConfigBuilder>.ConnectionMaxIdleMs

CommonClientConfigsBuilder<ProducerConfigBuilder>.WithConnectionMaxIdleMs(long)

CommonClientConfigsBuilder<ProducerConfigBuilder>.RequestTimeoutMs

CommonClientConfigsBuilder<ProducerConfigBuilder>.WithRequestTimeoutMs(int)

CommonClientConfigsBuilder<ProducerConfigBuilder>.DefaultListKeySerdeInnerClass

CommonClientConfigsBuilder<ProducerConfigBuilder>.WithDefaultListKeySerdeInnerClass(Class)

CommonClientConfigsBuilder<ProducerConfigBuilder>.DefaultListValueSerdeInnerClass

CommonClientConfigsBuilder<ProducerConfigBuilder>.WithDefaultListValueSerdeInnerClass(Class)

CommonClientConfigsBuilder<ProducerConfigBuilder>.DefaultListKeySerdeTypeClass

CommonClientConfigsBuilder<ProducerConfigBuilder>.WithDefaultListKeySerdeTypeClass(Class)

CommonClientConfigsBuilder<ProducerConfigBuilder>.DefaultListValueSerdeTypeClass

CommonClientConfigsBuilder<ProducerConfigBuilder>.WithDefaultListValueSerdeTypeClass(Class)

CommonClientConfigsBuilder<ProducerConfigBuilder>.EnableMetricsPush

CommonClientConfigsBuilder<ProducerConfigBuilder>.WithEnableMetricsPush(bool)

CommonClientConfigsBuilder<ProducerConfigBuilder>.GroupId

CommonClientConfigsBuilder<ProducerConfigBuilder>.WithGroupId(string)

CommonClientConfigsBuilder<ProducerConfigBuilder>.GroupInstanceId

CommonClientConfigsBuilder<ProducerConfigBuilder>.WithGroupInstanceId(string)

CommonClientConfigsBuilder<ProducerConfigBuilder>.MaxPollIntervalMs

CommonClientConfigsBuilder<ProducerConfigBuilder>.WithMaxPollIntervalMs(int)

CommonClientConfigsBuilder<ProducerConfigBuilder>.RebalanceTimeoutMs

CommonClientConfigsBuilder<ProducerConfigBuilder>.WithRebalanceTimeoutMs(int)

CommonClientConfigsBuilder<ProducerConfigBuilder>.SessionTimeoutMs

CommonClientConfigsBuilder<ProducerConfigBuilder>.WithSessionTimeoutMs(int)

CommonClientConfigsBuilder<ProducerConfigBuilder>.HeartbeatIntervalMs

CommonClientConfigsBuilder<ProducerConfigBuilder>.WithHeartbeatIntervalMs(int)

CommonClientConfigsBuilder<ProducerConfigBuilder>.DefaultApiTimeoutMs

CommonClientConfigsBuilder<ProducerConfigBuilder>.WithDefaultApiTimeoutMs(long)

GenericConfigBuilder<ProducerConfigBuilder>.Create()

GenericConfigBuilder<ProducerConfigBuilder>.CreateFrom(ProducerConfigBuilder)

GenericConfigBuilder<ProducerConfigBuilder>.PropertyChanged

GenericConfigBuilder<ProducerConfigBuilder>.ExistProperty(string)

GenericConfigBuilder<ProducerConfigBuilder>.GetProperty<TData>(string)

GenericConfigBuilder<ProducerConfigBuilder>.SetProperty(string, object)

GenericConfigBuilder<ProducerConfigBuilder>.Clone()

GenericConfigBuilder<ProducerConfigBuilder>.ToProperties()

GenericConfigBuilder<ProducerConfigBuilder>.ToMap()

GenericConfigBuilder<ProducerConfigBuilder>.AutoSelectBuffered

GenericConfigBuilder<ProducerConfigBuilder>.KeySerDesSelector

GenericConfigBuilder<ProducerConfigBuilder>.ValueSerDesSelector

GenericConfigBuilder<ProducerConfigBuilder>.BuildKeySerDes<TKey, TJVMTKey>()

GenericConfigBuilder<ProducerConfigBuilder>.BuildValueSerDes<TValue, TJVMTValue>()

GenericConfigBuilder<ProducerConfigBuilder>.Clear()

GenericConfigBuilder<ProducerConfigBuilder>.Dispose()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

Extension Methods

ProducerConfigBuilderExtensions.CanApplyBasicSerializer<T>(ProducerConfigBuilder)

ProducerConfigBuilderExtensions.WithKeySerializerClass(ProducerConfigBuilder, Type)

ProducerConfigBuilderExtensions.WithKeySerializerClass<T>(ProducerConfigBuilder)

ProducerConfigBuilderExtensions.WithValueSerializerClass(ProducerConfigBuilder, Type)

ProducerConfigBuilderExtensions.WithValueSerializerClass<T>(ProducerConfigBuilder)

Properties

Acks

Manages ACKS_CONFIG

public ProducerConfigBuilder.AcksTypes Acks { get; set; }

Property Value

ProducerConfigBuilder.AcksTypes

BatchSize

Manages BATCH_SIZE_CONFIG

public int BatchSize { get; set; }

Property Value

int

BufferMemory

Manages BUFFER_MEMORY_CONFIG

public long BufferMemory { get; set; }

Property Value

long

CompressionType

Manages COMPRESSION_TYPE_CONFIG

public ProducerConfigBuilder.CompressionTypes CompressionType { get; set; }

Property Value

ProducerConfigBuilder.CompressionTypes

DeliveryTimeoutMs

Manages DELIVERY_TIMEOUT_MS_CONFIG

public int DeliveryTimeoutMs { get; set; }

Property Value

int

EnableIdempotence

Manages ENABLE_IDEMPOTENCE_CONFIG

public bool EnableIdempotence { get; set; }

Property Value

bool

InterceptorClasses

Manages INTERCEPTOR_CLASSES_CONFIG

public List<Class> InterceptorClasses { get; set; }

Property Value

List<Class>

KeySerializerClass

Manages KEY_SERIALIZER_CLASS_CONFIG

public string KeySerializerClass { get; set; }

Property Value

string

LingerMs

Manages LINGER_MS_CONFIG

public long LingerMs { get; set; }

Property Value

long

MaxBlockMs

Manages MAX_BLOCK_MS_CONFIG

public long MaxBlockMs { get; set; }

Property Value

long

MaxInFlightRequestPerConnection

Manages MAX_IN_FLIGHT_REQUESTS_PER_CONNECTION

public int MaxInFlightRequestPerConnection { get; set; }

Property Value

int

MaxRequestSize

Manages MAX_REQUEST_SIZE_CONFIG

public int MaxRequestSize { get; set; }

Property Value

int

MetadataMaxIdle

Manages METADATA_MAX_IDLE_CONFIG

public long MetadataMaxIdle { get; set; }

Property Value

long

PartitionerAvailabilityTimeoutMs

Manages PARTITIONER_AVAILABILITY_TIMEOUT_MS_CONFIG

public long PartitionerAvailabilityTimeoutMs { get; set; }

Property Value

long

PartitionerClass

Manages PARTITIONER_CLASS_CONFIG

public Class PartitionerClass { get; set; }

Property Value

Class

PartitionerIgnoreKeys

Manages PARTITIONER_IGNORE_KEYS_CONFIG

public bool PartitionerIgnoreKeys { get; set; }

Property Value

bool

SecurityProviders

Manages SECURITY_PROVIDERS_CONFIG

public string SecurityProviders { get; set; }

Property Value

string

TransactionTimeout

Manages TRANSACTION_TIMEOUT_CONFIG

public int TransactionTimeout { get; set; }

Property Value

int

TransactionalId

Manages TRANSACTIONAL_ID_CONFIG

public string TransactionalId { get; set; }

Property Value

string

ValueSerializerClass

Manages VALUE_SERIALIZER_CLASS_CONFIG

public string ValueSerializerClass { get; set; }

Property Value

string

Methods

WithAcks(AcksTypes)

Manages ACKS_CONFIG

public ProducerConfigBuilder WithAcks(ProducerConfigBuilder.AcksTypes acks)

Parameters

acks ProducerConfigBuilder.AcksTypes

Returns

ProducerConfigBuilder

WithBatchSize(int)

Manages BATCH_SIZE_CONFIG

public ProducerConfigBuilder WithBatchSize(int batchSize)

Parameters

batchSize int

Returns

ProducerConfigBuilder

WithBufferMemory(long)

Manages BUFFER_MEMORY_CONFIG

public ProducerConfigBuilder WithBufferMemory(long bufferMemory)

Parameters

bufferMemory long

Returns

ProducerConfigBuilder

WithCompressionType(CompressionTypes)

Manages COMPRESSION_TYPE_CONFIG

public ProducerConfigBuilder WithCompressionType(ProducerConfigBuilder.CompressionTypes compressionType)

Parameters

compressionType ProducerConfigBuilder.CompressionTypes

Returns

ProducerConfigBuilder

WithDeliveryTimeoutMs(int)

Manages DELIVERY_TIMEOUT_MS_CONFIG

public ProducerConfigBuilder WithDeliveryTimeoutMs(int deliveryTimeoutMs)

Parameters

deliveryTimeoutMs int

Returns

ProducerConfigBuilder

WithEnableIdempotence(bool)

Manages ENABLE_IDEMPOTENCE_CONFIG

public ProducerConfigBuilder WithEnableIdempotence(bool enableIdempotence)

Parameters

enableIdempotence bool

Returns

ProducerConfigBuilder

WithInterceptorClasses(List<Class>)

Manages INTERCEPTOR_CLASSES_CONFIG

public ProducerConfigBuilder WithInterceptorClasses(List<Class> interceptorClasses)

Parameters

interceptorClasses List<Class>

Returns

ProducerConfigBuilder

WithKeySerializerClass(string)

Manages KEY_SERIALIZER_CLASS_CONFIG

public ProducerConfigBuilder WithKeySerializerClass(string keySerializerClass)

Parameters

keySerializerClass string

Returns

ProducerConfigBuilder

WithLingerMs(long)

Manages LINGER_MS_CONFIG

public ProducerConfigBuilder WithLingerMs(long lingerMs)

Parameters

lingerMs long

Returns

ProducerConfigBuilder

WithMaxBlockMs(long)

Manages MAX_BLOCK_MS_CONFIG

public ProducerConfigBuilder WithMaxBlockMs(long maxBlockMs)

Parameters

maxBlockMs long

Returns

ProducerConfigBuilder

WithMaxInFlightRequestPerConnection(int)

Manages MAX_IN_FLIGHT_REQUESTS_PER_CONNECTION

public ProducerConfigBuilder WithMaxInFlightRequestPerConnection(int maxInFlightRequestPerConnection)

Parameters

maxInFlightRequestPerConnection int

Returns

ProducerConfigBuilder

WithMaxRequestSize(int)

Manages MAX_REQUEST_SIZE_CONFIG

public ProducerConfigBuilder WithMaxRequestSize(int maxRequestSize)

Parameters

maxRequestSize int

Returns

ProducerConfigBuilder

WithMetadataMaxIdle(long)

Manages METADATA_MAX_IDLE_CONFIG

public ProducerConfigBuilder WithMetadataMaxIdle(long metadataMaxIdle)

Parameters

metadataMaxIdle long

Returns

ProducerConfigBuilder

WithPartitionerAvailabilityTimeoutMs(long)

Manages PARTITIONER_AVAILABILITY_TIMEOUT_MS_CONFIG

public ProducerConfigBuilder WithPartitionerAvailabilityTimeoutMs(long partitionerAvailabilityTimeoutMs)

Parameters

partitionerAvailabilityTimeoutMs long

Returns

ProducerConfigBuilder

WithPartitionerClass(Class)

Manages PARTITIONER_CLASS_CONFIG

public ProducerConfigBuilder WithPartitionerClass(Class partitionerClass)

Parameters

partitionerClass Class

Returns

ProducerConfigBuilder

WithPartitionerIgnoreKeys(bool)

Manages PARTITIONER_IGNORE_KEYS_CONFIG

public ProducerConfigBuilder WithPartitionerIgnoreKeys(bool partitionerIgnoreKeys)

Parameters

partitionerIgnoreKeys bool

Returns

ProducerConfigBuilder

WithSecurityProviders(string)

Manages SECURITY_PROVIDERS_CONFIG

public ProducerConfigBuilder WithSecurityProviders(string securityProviders)

Parameters

securityProviders string

Returns

ProducerConfigBuilder

WithTransactionTimeout(int)

Manages TRANSACTION_TIMEOUT_CONFIG

public ProducerConfigBuilder WithTransactionTimeout(int transactionTimeout)

Parameters

transactionTimeout int

Returns

ProducerConfigBuilder

WithTransactionalId(string)

Manages TRANSACTIONAL_ID_CONFIG

public ProducerConfigBuilder WithTransactionalId(string transactionalId)

Parameters

transactionalId string

Returns

ProducerConfigBuilder

WithValueSerializerClass(string)

Manages VALUE_SERIALIZER_CLASS_CONFIG

public ProducerConfigBuilder WithValueSerializerClass(string valueSerializerClass)

Parameters

valueSerializerClass string

Returns

ProducerConfigBuilder