KafkaRetriableException
Exception that instructs Kafka driver to instead of introspecting error processing flow and sending serialized error message to the consumer, force bubble it up to the "eachMessage" callback of the underlying "kafkajs" package (even if interceptors are applied, or an observable stream is returned from the message handler).
class KafkaRetriableException extends RpcException {
getError(): string | object
// inherited from nest/packages/microservices/RpcException
constructor(error: string | object)
initMessage()
getError(): string | object
}
Methods
getError() |
|---|
ParametersThere are no parameters. Returns
|
Description
A transient exception that if retried may succeed.