Function isFatalProducerError

packages/queue/src/kafka.ts:154–170

(err: unknown)

const FATAL_PRODUCER_ERROR_CODES = new Set<number>([45, 46, 47, 65]);

const isFatalProducerError = (err: unknown): boolean => {
  if (!err || typeof err !== 'object') {
    return false;
  }
  const name = (err as { name?: string }).name;
  // Retries-exceeded leaves the idempotent producer's sequence state
  // suspect (broker may have persisted a batch we gave up on), so treat
  // it as fatal-for-this-producer too.
  if (name === 'KafkaJSNumberOfRetriesExceeded') {
    return true;
  }
  if (name === 'KafkaJSProtocolError') {
    const code = (err as { code?: number }).code;
    return typeof code === 'number' && FATAL_PRODUCER_ERROR_CODES.has(code);
  }
  return false;
};

const resetProducer = (broken: Producer): void => {
  if (producer !== broken) {