Class KafkaIO

constructor

• new KafkaIO(options?: KafkaAdapterOptions): KafkaIO

  Parameters

  • options: KafkaAdapterOptions = {}

  Returns KafkaIO

capabilities

name

destroy

• destroy(): void

  Clean up resources used by the IO adapter

  Returns void

getGroupId

• getGroupId(): string

  Returns string

getSessionId

• getSessionId(): string

  Returns string

getTopic

• getTopic(): string

  Returns string

read

• read(): Promise<null | string | IoMessage>

  Returns Promise<null | string | IoMessage>

signalDestroy

• signalDestroy(): Promise<void>

  Signal that the IO adapter should prepare for destruction

  Returns Promise<void>

write

• write(message: string | IoMessage): Promise<void>

  Parameters

  • message: string | IoMessage

  Returns Promise<void>