xk6-kafka

---

Class: Connection

Defined in: index.d.ts:483

Deprecated

Use AdminClient instead. Connection remains as a compatibility alias in v2.x.

Constructors

Constructor

new Connection(connectionConfig): Connection

Defined in: index.d.ts:490

Parameters

connectionConfig

ConnectionConfig

Connection configuration.

Returns

Connection

• Connection instance.

Methods

close()

close(): void

Defined in: index.d.ts:516

Returns

void

• Nothing.

Destructor

Description

Close the connection.

---

createTopic()

createTopic(topicConfig): void

Defined in: index.d.ts:497

Parameters

topicConfig

TopicConfig

Topic configuration.

Returns

void

• Nothing.

Method

Create a new topic.

---

deleteTopic()

deleteTopic(topic): void

Defined in: index.d.ts:504

Parameters

topic

string

Topic name.

Returns

void

• Nothing.

Method

Delete a topic.

---

listTopics()

listTopics(): string[]

Defined in: index.d.ts:510

Returns

string[]

• Topics.

Method

List topics.