terafoundation_kafka_connector / helpers

helpers

Functions

getClientOptions()

getClientOptions(config, ...options): RDKafkaOptions

Defined in: helpers.ts:46

Parameters

Parameter	Type
config	KafkaConnectorConfig
...options	any[]

Returns

RDKafkaOptions

---

getConsumerOptions()

getConsumerOptions(config, settings): object

Defined in: helpers.ts:8

Parameters

Parameter	Type
config	KafkaConnectorConfig
settings	KafkaConsumerSettings

Returns

object

clientOptions

clientOptions: RDKafkaOptions

group

group: string | undefined

topicOptions

topicOptions: RDKafkaOptions

---

getProducerOptions()

getProducerOptions(config, settings): object

Defined in: helpers.ts:30

Parameters

Parameter	Type
config	KafkaConnectorConfig
settings	KafkaProducerSettings

Returns

object

clientOptions

clientOptions: RDKafkaOptions

pollInterval

pollInterval: number

topicOptions

topicOptions: RDKafkaOptions