Class ConsumeException
Represents an error that occurred during message consumption.
Implements
Inherited Members
Namespace: Confluent.Kafka
Assembly: Confluent.Kafka.dll
Syntax
public class ConsumeException : KafkaException, ISerializableConstructors
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 occurred. |
| Error | error | The error that occurred. |
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 occurred. |
| Error | error | The error that occurred. |
| 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 occurred.
Declaration
public ConsumeResult<byte[], byte[]> ConsumerRecord { get; }Property Value
| Type | Description |
|---|---|
| ConsumeResult<byte[], byte[]> |