terafoundation_kafka_connector / helpers

helpers

Functions

getAdminOptions()

getAdminOptions(config, settings): object

Defined in: helpers.ts:45

Parameters

Parameter	Type
config	KafkaConnectorConfig
settings	KafkaAdminSettings

Returns

object

clientOptions

clientOptions: RDKafkaOptions

---

getClientOptions()

getClientOptions(config, ...options): RDKafkaOptions

Defined in: helpers.ts:55

Parameters

Parameter	Type
config	KafkaConnectorConfig
...options	any[]

Returns

RDKafkaOptions

---

getConsumerOptions()

getConsumerOptions(config, settings): object

Defined in: helpers.ts:9

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:31

Parameters

Parameter	Type
config	KafkaConnectorConfig
settings	KafkaProducerSettings

Returns

object

clientOptions

clientOptions: RDKafkaOptions

pollInterval

pollInterval: number

topicOptions

topicOptions: RDKafkaOptions