Class KafkaConnections

Inheritance
object
System.Collections.Generic.Dictionary<TKey, TValue><string, Confluent.Kafka.ClientConfig>
KafkaConnections
Implements
System.Collections.Generic.IDictionary<TKey, TValue><string, Confluent.Kafka.ClientConfig>
System.Collections.Generic.ICollection<T><KeyValuePair<string, Confluent.Kafka.ClientConfig>>
System.Collections.IDictionary
System.Collections.ICollection
System.Collections.Generic.IReadOnlyDictionary<TKey, TValue><string, Confluent.Kafka.ClientConfig>
System.Collections.Generic.IReadOnlyCollection<T><KeyValuePair<string, Confluent.Kafka.ClientConfig>>
System.Collections.Generic.IEnumerable<T><KeyValuePair<string, Confluent.Kafka.ClientConfig>>
System.Collections.IEnumerable
System.Runtime.Serialization.ISerializable
System.Runtime.Serialization.IDeserializationCallback
Inherited Members
System.Collections.Generic.Dictionary<string, Confluent.Kafka.ClientConfig>.Add(string, Confluent.Kafka.ClientConfig)
System.Collections.Generic.Dictionary<string, Confluent.Kafka.ClientConfig>.Clear()
System.Collections.Generic.Dictionary<string, Confluent.Kafka.ClientConfig>.ContainsKey(string)
System.Collections.Generic.Dictionary<string, Confluent.Kafka.ClientConfig>.ContainsValue(Confluent.Kafka.ClientConfig)
System.Collections.Generic.Dictionary<string, Confluent.Kafka.ClientConfig>.GetEnumerator()
System.Collections.Generic.Dictionary<string, Confluent.Kafka.ClientConfig>.GetObjectData(System.Runtime.Serialization.SerializationInfo, System.Runtime.Serialization.StreamingContext)
System.Collections.Generic.Dictionary<string, Confluent.Kafka.ClientConfig>.OnDeserialization(object)
System.Collections.Generic.Dictionary<string, Confluent.Kafka.ClientConfig>.Remove(string)
System.Collections.Generic.Dictionary<string, Confluent.Kafka.ClientConfig>.Remove(string, out Confluent.Kafka.ClientConfig)
System.Collections.Generic.Dictionary<string, Confluent.Kafka.ClientConfig>.TryGetValue(string, out Confluent.Kafka.ClientConfig)
System.Collections.Generic.Dictionary<string, Confluent.Kafka.ClientConfig>.TryAdd(string, Confluent.Kafka.ClientConfig)
System.Collections.Generic.Dictionary<string, Confluent.Kafka.ClientConfig>.EnsureCapacity(int)
System.Collections.Generic.Dictionary<string, Confluent.Kafka.ClientConfig>.TrimExcess()
System.Collections.Generic.Dictionary<string, Confluent.Kafka.ClientConfig>.TrimExcess(int)
System.Collections.Generic.Dictionary<string, Confluent.Kafka.ClientConfig>.Comparer
System.Collections.Generic.Dictionary<string, Confluent.Kafka.ClientConfig>.Count
System.Collections.Generic.Dictionary<string, Confluent.Kafka.ClientConfig>.Keys
System.Collections.Generic.Dictionary<string, Confluent.Kafka.ClientConfig>.Values
System.Collections.Generic.Dictionary<string, Confluent.Kafka.ClientConfig>.this[string]
object.GetType()
object.MemberwiseClone()
object.ToString()
object.Equals(object)
object.Equals(object, object)
object.ReferenceEquals(object, object)
object.GetHashCode()
Namespace: Volo.Abp.Kafka
Assembly: Volo.Abp.Kafka.dll
Syntax
public class KafkaConnections : Dictionary<string, ClientConfig>, IDictionary<string, ClientConfig>, ICollection<KeyValuePair<string, ClientConfig>>, IDictionary, ICollection, IReadOnlyDictionary<string, ClientConfig>, IReadOnlyCollection<KeyValuePair<string, ClientConfig>>, IEnumerable<KeyValuePair<string, ClientConfig>>, IEnumerable, ISerializable, IDeserializationCallback

Constructors

KafkaConnections()

Declaration
public KafkaConnections()

Fields

DefaultConnectionName

Declaration
public const string DefaultConnectionName = "Default"
Field Value
Type Description
string

Properties

Default

Declaration
public ClientConfig Default { get; set; }
Property Value
Type Description
Confluent.Kafka.ClientConfig

Methods

GetOrDefault(string)

Declaration
public ClientConfig GetOrDefault(string connectionName)
Parameters
Type Name Description
string connectionName
Returns
Type Description
Confluent.Kafka.ClientConfig

Implements

System.Collections.Generic.IDictionary<TKey, TValue>
System.Collections.Generic.ICollection<T>
System.Collections.IDictionary
System.Collections.ICollection
System.Collections.Generic.IReadOnlyDictionary<TKey, TValue>
System.Collections.Generic.IReadOnlyCollection<T>
System.Collections.Generic.IEnumerable<T>
System.Collections.IEnumerable
System.Runtime.Serialization.ISerializable
System.Runtime.Serialization.IDeserializationCallback

Extension Methods