KafkaParser

  
class KafkaParser {
  constructor(config?: KafkaParserConfig)
  protected keepBinary: boolean
  parse<T = any>(data: any): T
  decode(value: Buffer): object | string | null | Buffer
}

Constructor


constructor(config?: KafkaParserConfig)

Parameters

Option Type Description
config KafkaParserConfig

Optional. Default is undefined.

Properties

Property Description
protected keepBinary: boolean Read-only.

Methods

parse()


parse<T = any>(data: any): T

Parameters

Option Type Description
data any

Returns

T

decode()


decode(value: Buffer): object | string | null | Buffer

Parameters

Option Type Description
value Buffer

Returns

object | string | null | Buffer