import { Message } from "kafka-node"; /** * Error indicates that your messageConsumer did not finish handling message * within a given */ export default class ConsumeTimeoutError extends Error { private timedOutMessage; private timeout; private groupId; /** * @param timedOutMessage - Message of for this timeout error * @param timeout - Configured timeout of the consumer * @param groupId - Configured group id of the consumer */ constructor(timedOutMessage: Message, timeout: number, groupId: string); readonly name: string; }