Skip to main content

terafoundation_kafka_connector / test-helpers/helpers

test-helpers/helpers

Functions

makeAdminClient()

makeAdminClient(config, logger?): Promise<KafkaAdminResult>

Defined in: test-helpers/helpers.ts:9

Parameters

ParameterType
configKafkaConnectorConfig
loggerLogger

Returns

Promise<KafkaAdminResult>


makeConsumerClient()

makeConsumerClient(config, logger?): Promise<KafkaConsumerResult>

Defined in: test-helpers/helpers.ts:17

Parameters

ParameterType
configKafkaConnectorConfig
loggerLogger

Returns

Promise<KafkaConsumerResult>


makeProducerClient()

makeProducerClient(config, logger?): Promise<KafkaProducerResult>

Defined in: test-helpers/helpers.ts:25

Parameters

ParameterType
configKafkaConnectorConfig
loggerLogger

Returns

Promise<KafkaProducerResult>