Pinned Loading

1. kafka consume and exit kafka consume and exit

   1

   import { Consumer, Kafka, KafkaMessage } from 'kafkajs'

   2

   3

   type OffsetRecord = { topic: string; partition: number; offset: string }

   4

   5

   const convertOffsets = (offsets: Map<string, bigint>): OffsetRecord[] => {