Namespace Confluent.Kafka
Classes
AdminClientBuilder
A builder for IAdminClient.
AdminClientConfig
AdminClient configuration properties
BrokerMetadata
Metadata pertaining to a single Kafka broker.
ClientConfig
Configuration common to all clients
ClientExtensions
IClient extension methods
CommittedOffsets
Encapsulates information provided to a Consumer's OnOffsetsCommitted event - per-partition offsets and success/error together with overall success/error of the commit operation.
Config
Base functionality common to all configuration classes.
ConfigPropertyNames
Names of all configuration properties specific to the .NET Client.
ConfigPropertyNames.Consumer
Consumer specific configuration properties.
ConfigPropertyNames.Producer
Producer specific configuration properties.
ConsumeException
Represents an error that occured during message consumption.
ConsumerBuilder<TKey, TValue>
A builder class for IConsumer<TKey, TValue>.
ConsumerConfig
Consumer configuration properties
ConsumeResult<TKey, TValue>
Represents a message consumed from a Kafka cluster.
DeliveryReport<TKey, TValue>
The result of a produce request.
DeliveryResult<TKey, TValue>
Encapsulates the result of a successful produce request.
DependentAdminClientBuilder
A builder class for IAdminClient instance implementations that leverage an existing client handle.
DependentProducerBuilder<TKey, TValue>
A builder class for IProducer<TKey, TValue> instance implementations that leverage an existing client handle.
[API-SUBJECT-TO-CHANGE] - This class may be removed in the future in favor of an improved API for this functionality.
Deserializers
Deserializers for use with Confluent.Kafka.Consumer`2.
Error
Represents an error that occured when interacting with a Kafka broker or the librdkafka library.
ErrorCodeExtensions
Provides extension methods on the ErrorCode enumeration.
GroupInfo
Encapsulates information describing a particular Kafka group.
GroupMemberInfo
Encapsulates information describing a particular member of a Kafka group.
Handle
A handle for a librdkafka client instance. Also encapsulates a reference to the IClient instance that owns this handle.
Header
Represents a kafka message header.
Headers
A collection of Kafka message headers.
Ignore
A type for use in conjunction with IgnoreDeserializer that enables message keys or values to be read as null, regardless of their value.
KafkaException
Represents an error that occured during an interaction with Kafka.
KafkaRetriableException
Represents an error where the operation that caused it may be retried.
KafkaTxnRequiresAbortException
Represents an error that caused the current transaction to fail and enter the abortable state.
Library
Methods that relate to the native librdkafka library itself (do not require a Producer or Consumer broker connection).
Loggers
OnLog callback event handler implementations.
LogMessage
Encapsulates information provided to the Producer/Consumer OnLog event.
Message<TKey, TValue>
Represents a (deserialized) Kafka message.
MessageMetadata
All components of Message<TKey, TValue> except Key and Value.
MessageNullException
Thrown when there is an attempt to dereference a null Message reference.
Metadata
Kafka cluster metadata.
Null
A type for use in conjunction with NullSerializer and NullDeserializer that enables null key or values to be enforced when producing or consuming messages.
PartitionMetadata
Metadata pertaining to a single Kafka topic partition.
ProduceException<TKey, TValue>
Represents an error that occured whilst producing a message.
ProducerBuilder<TKey, TValue>
A builder class for IProducer<TKey, TValue>.
ProducerConfig
Producer configuration properties
Serializers
Serializers for use with Confluent.Kafka.Producer`2.
TopicMetadata
Metadata pertaining to a single Kafka topic.
TopicPartition
Represents a Kafka (topic, partition) tuple.
TopicPartitionError
Represents a Kafka (topic, partition, error) tuple.
TopicPartitionException
Represents an error that occured during a Consumer.Position request.
TopicPartitionOffset
Represents a Kafka (topic, partition, offset) tuple.
TopicPartitionOffsetError
Represents a Kafka (topic, partition, offset, error) tuple.
TopicPartitionOffsetException
Represents an error that occured during a Consumer.Position request.
TopicPartitionTimestamp
Represents a Kafka (topic, partition, timestamp) tuple.
WatermarkOffsets
Represents the low and high watermark offsets of a Kafka topic/partition.
Structs
Offset
Represents a Kafka partition offset value.
Partition
Represents a Kafka partition.
SerializationContext
Context relevant to a serialization or deserialization operation.
Timestamp
Encapsulates a Kafka timestamp and its type.
Interfaces
IAdminClient
Defines an Apache Kafka admin client.
IAsyncDeserializer<T>
A deserializer for use with Confluent.Kafka.Consumer`2.
IAsyncSerializer<T>
Defines a serializer for use with Confluent.Kafka.Producer`2.
IClient
Defines methods common to all client types.
IConsumer<TKey, TValue>
Defines a high-level Apache Kafka consumer (with key and value deserialization).
IConsumerGroupMetadata
The consumer group metadata associated with a consumer.
IDeserializer<T>
Defines a deserializer for use with Confluent.Kafka.Consumer`2.
IHeader
Defines a Kafka message header.
IProducer<TKey, TValue>
Defines a high-level Apache Kafka producer client that provides key and value serialization.
ISerializer<T>
Defines a serializer for use with Confluent.Kafka.Producer`2.
Enums
Acks
Acks enum values
AutoOffsetReset
AutoOffsetReset enum values
BrokerAddressFamily
BrokerAddressFamily enum values
CompressionType
CompressionType enum values
ErrorCode
Enumeration of local and broker generated error codes.
IsolationLevel
IsolationLevel enum values
LogLevelType
Enumerates different log level enumerations.
MessageComponentType
Enumerates different parts of a Kafka message
PartitionAssignmentStrategy
PartitionAssignmentStrategy enum values
Partitioner
Partitioner enum values
PersistenceStatus
Enumeration of possible message persistence states.
SaslMechanism
SaslMechanism enum values
SaslOauthbearerMethod
SaslOauthbearerMethod enum values
SecurityProtocol
SecurityProtocol enum values
SslEndpointIdentificationAlgorithm
SslEndpointIdentificationAlgorithm enum values
SyslogLevel
Represents enumeration with levels coming from syslog(3)
TimestampType
Enumerates the different meanings of a message timestamp value.
Delegates
PartitionerDelegate
Calculate a partition number given a partitionCount
and serialized keyData. The topic
is also provided, but is typically not used.