@kaluza/kafka-node-avro

Index

Classes

Interfaces

Type aliases

Functions

Type aliases

OnErrorCallback

OnErrorCallback: function

Type declaration

- (error: Error): void
- Parameters
  - error: Error
  Returns void

OnMessageCallback

OnMessageCallback: function

Type declaration

- (message: ConsumerMessage): void
- Parameters
  - message: ConsumerMessage
  Returns void

Functions

Const createClients

createClients(params: ClientsParams): Promise<KafkaClients>

- Defined in index.ts:25
Parameters
- params: ClientsParams
Returns Promise<KafkaClients>

Const getSSLOptions

getSSLOptions(options: SSLOptions): CommonConfig

- Defined in util/ssl.ts:17
Parameters
- options: SSLOptions
Returns CommonConfig

Const writeValueToFile

writeValueToFile(filename: string, value: string): string

- Defined in util/ssl.ts:7
Parameters
- filename: string
- value: string
Returns string

Generated using TypeDoc