Home - News ( United States | United Kingdom | Italy | Germany ) - Football scores

Showing content from https://docs.confluent.io/current/clients/confluent-kafka-dotnet/api/Confluent.Kafka.html below:

Namespace Confluent.Kafka | Confluent.Kafka

A builder for IAdminClient.

AdminClient configuration properties

Metadata pertaining to a single Kafka broker.

Configuration common to all clients

IClient extension methods

Encapsulates information provided to a Consumer's OnOffsetsCommitted event - per-partition offsets and success/error together with overall success/error of the commit operation.

Base functionality common to all configuration classes.

Names of all configuration properties specific to the .NET Client.

Consumer specific configuration properties.

Producer specific configuration properties.

Represents an error that occured during message consumption.

Represents a message consumed from a Kafka cluster.

A builder class for IConsumer<TKey, TValue>.

Consumer configuration properties

Represents a Kafka tuple (consumer group, list of TopicPartitionOffsets).

Represents a Kafka tuple (consumer group, list of TopicPartions).

The result of a produce request.

Encapsulates the result of a successful produce request.

A builder class for IAdminClient instance implementations that leverage an existing client handle.

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 for use with Confluent.Kafka.Consumer<TKey, TValue>.

Represents an error that occured when interacting with a Kafka broker or the librdkafka library.

Provides extension methods on the ErrorCode enumeration.

Encapsulates information describing a particular Kafka group.

Encapsulates information describing a particular member of a Kafka group.

A handle for a librdkafka client instance. Also encapsulates a reference to the IClient instance that owns this handle.

Represents a kafka message header.

A collection of Kafka message headers.

Extension methods for default IAdminClient implementations.

Common extension methods for IConsumer<TKey, TValue> implementations.

A type for use in conjunction with IgnoreDeserializer that enables message keys or values to be read as null, regardless of their value.

Represents an error that occured during an interaction with Kafka.

Represents an error where the operation that caused it may be retried.

Represents an error that caused the current transaction to fail and enter the abortable state.

Methods that relate to the native librdkafka library itself (do not require a Producer or Consumer broker connection).

Encapsulates information provided to the Producer/Consumer OnLog event.

OnLog callback event handler implementations.

All components of Message<TKey, TValue> except Key and Value.

Thrown when there is an attempt to dereference a null Message reference.

Represents a (deserialized) Kafka message.

Kafka cluster metadata.

Node represents a Kafka broker.

A type for use in conjunction with NullSerializer and NullDeserializer that enables null key or values to be enforced when producing or consuming messages.

Metadata pertaining to a single Kafka topic partition.

Represents an error that occured whilst producing a message.

A builder class for IProducer<TKey, TValue>.

Producer configuration properties

Serializers for use with Confluent.Kafka.Producer<TKey, TValue>.

A class used to represent a collection of topics.

Metadata pertaining to a single Kafka topic.

Represents a Kafka (topic, partition) tuple.

Represents a Kafka (topic, partition, error) tuple.

Represents an error that occured during a Consumer.Position request.

TopicPartitionInfo represents the description of a partition within a topic. Used for result of DescribeTopics for an individual topic.

Represents a Kafka (topic, partition, offset) tuple.

Represents a Kafka (topic, partition, offset, error) tuple.

Represents an error that occured during a Consumer.Position request.

Represents a Kafka (topic, partition, timestamp) tuple.

Represents a UUID

Represents the low and high watermark offsets of a Kafka topic/partition.

Represents a Kafka partition offset value.

Represents a Kafka partition.

Context relevant to a serialization or deserialization operation.

Encapsulates a Kafka timestamp and its type.

Defines an Apache Kafka admin client.

A deserializer for use with Confluent.Kafka.Consumer<TKey, TValue>.

Defines a serializer for use with Confluent.Kafka.Producer<TKey, TValue>.

Defines methods common to all client types.

The consumer group metadata associated with a consumer.

Defines a high-level Apache Kafka consumer (with key and value deserialization).

Defines a deserializer for use with Confluent.Kafka.Consumer<TKey, TValue>.

Defines a Kafka message header.

Defines a high-level Apache Kafka producer client that provides key and value serialization.

Defines a serializer for use with Confluent.Kafka.Producer<TKey, TValue>.

Acks enum values

AutoOffsetReset enum values

BrokerAddressFamily enum values

ClientDnsLookup enum values

CompressionType enum values

Enumerates the different consumer group states.

Enumerates the different consumer group types.

Enumerates the different types of Election types.

Enumeration of local and broker generated error codes.

GroupProtocol enum values

IsolationLevel enum values

Enumerates different log level enumerations.

Enumerates different parts of a Kafka message

MetadataRecoveryStrategy enum values

PartitionAssignmentStrategy enum values

Partitioner enum values

Enumeration of possible message persistence states.

SaslMechanism enum values

SaslOauthbearerAssertionAlgorithm enum values

SaslOauthbearerGrantType enum values

SaslOauthbearerMethod enum values

SecurityProtocol enum values

SslEndpointIdentificationAlgorithm enum values

Represents enumeration with levels coming from syslog(3)

Enumerates the different meanings of a message timestamp value.

Calculate a partition number given a partitionCount and serialized keyData. The topic is also provided, but is typically not used.

RetroSearch is an open source project built by @garambo | Open a GitHub Issue

Search and Browse the WWW like it's 1997 | Search results from DuckDuckGo

HTML: 3.2 | Encoding: UTF-8 | Version: 0.7.4