Class KafkaException

Represents an error that occured during an interaction with Kafka.

Inheritance

object

Exception

KafkaException

AlterConfigsException

AlterConsumerGroupOffsetsException

AlterUserScramCredentialsException

CreateAclsException

CreatePartitionsException

CreateTopicsException

DeleteAclsException

DeleteConsumerGroupOffsetsException

DeleteGroupsException

DeleteRecordsException

DeleteTopicsException

DescribeAclsException

DescribeConfigsException

DescribeConsumerGroupsException

DescribeTopicsException

DescribeUserScramCredentialsException

ElectLeadersException

IncrementalAlterConfigsException

ListConsumerGroupOffsetsException

ListConsumerGroupsException

ListOffsetsException

ConsumeException

KafkaRetriableException

KafkaTxnRequiresAbortException

ProduceException<TKey, TValue>

TopicPartitionException

TopicPartitionOffsetException

Implements

ISerializable

Inherited Members

Exception.GetBaseException()

Exception.GetObjectData(SerializationInfo, StreamingContext)

Exception.GetType()

Exception.ToString()

Exception.Data

Exception.HelpLink

Exception.HResult

Exception.InnerException

Exception.Message

Exception.Source

Exception.StackTrace

Exception.TargetSite

Exception.SerializeObjectState

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

Namespace: Confluent.Kafka

Assembly: Confluent.Kafka.dll

Syntax

public class KafkaException : Exception, ISerializable

Constructors

KafkaException(Error)

Initialize a new instance of KafkaException based on an existing Error instance.

Declaration

public KafkaException(Error error)

Parameters

Type	Name	Description
Error	error	The Kafka Error.

KafkaException(Error, Exception)

Initialize a new instance of KafkaException based on an existing Error instance and inner exception.

Declaration

public KafkaException(Error error, Exception innerException)

Parameters

Type	Name	Description
Error	error	The Kafka Error.
Exception	innerException	The exception instance that caused this exception.

KafkaException(ErrorCode)

Initialize a new instance of KafkaException based on an existing ErrorCode value.

Declaration

public KafkaException(ErrorCode code)

Parameters

Type	Name	Description
ErrorCode	code	The Kafka ErrorCode.

Properties

Error

Gets the Error associated with this KafkaException.

Declaration

public Error Error { get; }

Property Value

Type	Description
Error

Implements

ISerializable