Class ConsumeException

Represents an error that occured during message consumption.

Inheritance

object

Exception

KafkaException

ConsumeException

Implements

ISerializable

Inherited Members

KafkaException.Error

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 ConsumeException : KafkaException, ISerializable

Constructors

ConsumeException(ConsumeResult<byte[], byte[]>, Error)

Initialize a new instance of ConsumeException

Declaration

public ConsumeException(ConsumeResult<byte[], byte[]> consumerRecord, Error error)

Parameters

Type	Name	Description
ConsumeResult<byte[], byte[]>	consumerRecord	An object that provides information know about the consumer record for which the error occured.
Error	error	The error that occured.

ConsumeException(ConsumeResult<byte[], byte[]>, Error, Exception)

Initialize a new instance of ConsumeException

Declaration

public ConsumeException(ConsumeResult<byte[], byte[]> consumerRecord, Error error, Exception innerException)

Parameters

Type	Name	Description
ConsumeResult<byte[], byte[]>	consumerRecord	An object that provides information know about the consumer record for which the error occured.
Error	error	The error that occured.
Exception	innerException	The exception instance that caused this exception.

Properties

ConsumerRecord

An object that provides information known about the consumer record for which the error occured.

Declaration

public ConsumeResult<byte[], byte[]> ConsumerRecord { get; }

Property Value

Type	Description
ConsumeResult<byte[], byte[]>

Implements

ISerializable