UNPKG

764 BJavaScriptView Raw
1"use strict";
2Object.defineProperty(exports, "__esModule", { value: true });
3exports.KafkaRetriableException = void 0;
4const 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 */
15class KafkaRetriableException extends rpc_exception_1.RpcException {
16 getError() {
17 return this;
18 }
19}
20exports.KafkaRetriableException = KafkaRetriableException;