1 | ;
|
2 | Object.defineProperty(exports, "__esModule", { value: true });
|
3 | exports.KafkaRetriableException = void 0;
|
4 | const rpc_exception_1 = require("./rpc-exception");
|
5 | /**
|
6 | * Exception that instructs Kafka driver to instead of introspecting
|
7 | * error processing flow and sending serialized error message to the consumer,
|
8 | * force bubble it up to the "eachMessage" callback of the underlying "kafkajs" package
|
9 | * (even if interceptors are applied, or an observable stream is returned from the message handler).
|
10 | *
|
11 | * A transient exception that if retried may succeed.
|
12 | *
|
13 | * @publicApi
|
14 | */
|
15 | class KafkaRetriableException extends rpc_exception_1.RpcException {
|
16 | getError() {
|
17 | return this;
|
18 | }
|
19 | }
|
20 | exports.KafkaRetriableException = KafkaRetriableException;
|