Kafka Consumer Exits Prematurely After Running Effect

const program = Effect.gen(function* () {
  const kafka = yield* Kafka
  const runtime = yield* Effect.runtime()

  const consumer = kafka.consumer({
    groupId: "my-group-id",
  })

  yield* Effect.tryPromise(consumer.connect)
  yield* Effect.tryPromise(() => consumer.subscribe({ topic }))
  yield* Effect.tryPromise(() =>
    consumer.run({
      eachMessage: ({ message }) =>
        Effect.logDebug("[CONSUMER] Received message").pipe(
          Effect.annotateLogs("kafkaMessage", message),
          Effect.provide(runtime),
          Effect.runPromise,
        ),
    }),
  )
})

yield* Effect.forever(Effect.void);