apache-kafka - NestJS-Kafka 组 id 在我在代码中更新后没有改变

Question

我正在使用 Kafka JS 连接到 kafka。在我的消费者中，最初我将我的组 id 命名为“orderable-test”，后来当我将此组 id 更新为“orderable-test-1”并重新运行我的代码时，组 id 仍然是“orderable-test”。即使我完全注释掉这个消费者并在不同的文件中编写另一个具有不同组 id 的消费者，它仍然给我这个“可订购测试”作为组 id 而不是新的。我想知道它的原因是什么，我该如何解决这个问题。

下面是我写的代码示例。

const consumer = kafka.consumer({ groupId: 'order-create-test' });
export class OrderInfoController {

  constructor(private readonly OrderInfoService: OrderInfoService) {}
   
  async onModuleInit() { 
    await consumer.connect();
    this.CreateOrderConsumer(consumer);
  }
  async onModuleDestroy() {
    await consumer.disconnect();
  }
  async CreateOrderConsumer(consumer){

    await consumer.subscribe({ topic: 'test-order', fromBeginning: true });
    await consumer.run({
      eachMessage: async ({ topic, partition, message }) => {
        console.log({
          topic, partition,
          message:{
          key: message.key.toString(),
          value: message.value.toString(),
        }})
        
      },
    });

  }