Class ConsumeException

Represents an error that occured during message consumption.

Inheritance

System.Object

System.Exception

KafkaException

ConsumeException

Implements

System.Runtime.Serialization.ISerializable

System.Runtime.InteropServices._Exception

Inherited Members

KafkaException.Error

System.Exception.GetBaseException()

System.Exception.ToString()

System.Exception.GetObjectData(System.Runtime.Serialization.SerializationInfo, System.Runtime.Serialization.StreamingContext)

System.Exception.GetType()

System.Exception.Message

System.Exception.Data

System.Exception.InnerException

System.Exception.TargetSite

System.Exception.StackTrace

System.Exception.HelpLink

System.Exception.Source

System.Exception.HResult

System.Exception.SerializeObjectState

System.Object.Equals(System.Object)

System.Object.Equals(System.Object, System.Object)

System.Object.ReferenceEquals(System.Object, System.Object)

System.Object.GetHashCode()

System.Object.MemberwiseClone()

Namespace: Confluent.Kafka

Assembly: cs.temp.dll.dll

Syntax

public class ConsumeException : KafkaException, ISerializable, _Exception

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<System.Byte[], System.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<System.Byte[], System.Byte[]>	consumerRecord	An object that provides information know about the consumer record for which the error occured.
Error	error	The error that occured.
System.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<System.Byte[], System.Byte[]>

Implements

System.Runtime.Serialization.ISerializable

System.Runtime.InteropServices._Exception