nestjs/nest · error · Error

Method is not supported for Kafka server

Error message

Method is not supported for Kafka server

What it means

Error "Method is not supported for Kafka server" thrown in nestjs/nest.

Source

Thrown at packages/microservices/server/server-kafka.ts:273

        this.send(replayStream$, publish);
      },
    );
  }

  public unwrap<T>(): T {
    if (!this.client) {
      throw new Error(
        'Not initialized. Please call the "listen"/"startAllMicroservices" method before accessing the server.',
      );
    }
    return [this.client, this.consumer, this.producer] as T;
  }

  public on<
    EventKey extends string | number | symbol = string | number | symbol,
    EventCallback = any,
  >(event: EventKey, callback: EventCallback) {
    throw new Error('Method is not supported for Kafka server');
  }

  private combineStreamsAndThrowIfRetriable(
    response$: Observable<any>,
    replayStream$: ReplaySubject<unknown>,
  ) {
    return new Promise<void>((resolve, reject) => {
      let isPromiseResolved = false;
      response$.subscribe({
        next: val => {
          replayStream$.next(val);
          if (!isPromiseResolved) {
            isPromiseResolved = true;
            resolve();
          }
        },
        error: err => {
          if (err instanceof KafkaRetriableException && !isPromiseResolved) {

View on GitHub (pinned to 6ec0e2783d)

Solutions

1. Do not register event handlers via server.on() on a Kafka server; Kafka transport does not support it.
2. Use Kafka consumer/producer event instrumentation (consumer.on / producer.on) via the client instead, or NestJS EventEmitter for app-level events.

Example fix

// Instead of server.on('error', cb), hook into the consumer:
const consumer = kafkaClient.consumer({ groupId: 'g' });
consumer.on(consumer.events.CRASH, cb);

When it happens

Trigger: Thrown at packages/microservices/server/server-kafka.ts:273 when the library encounters an invalid state.

Common situations: See trigger scenarios.

AI-assisted analysis of nestjs/nest@6ec0e2783d (2026-08-03). Data as JSON: /data/errors/82a50383123859b3.json. Report an issue: GitHub.