Class TopicAdministrator

Hierarchy

TopicAdministrator

Index

Constructors

constructor

Properties

Methods

Object literals

adminClientConfiguration

Constructors

constructor

new TopicAdministrator(kafka: Kafka, topicConfig?: Omit<ITopicConfig, "topic">, adminConfig?: AdminConfig): TopicAdministrator

- Defined in src/topic_administrator.ts:10
Parameters
- kafka: Kafka
- Default value topicConfig: Omit<ITopicConfig, "topic"> = {}
- Default value adminConfig: AdminConfig = TopicAdministrator.adminClientConfiguration
Returns TopicAdministrator

Properties

Protected adminConfig

adminConfig: AdminConfig

Protected kafka

kafka: Kafka

Protected topicConfig

topicConfig: Omit<ITopicConfig, "topic">

Methods

createTopic

createTopic(topic: string): Promise<void>

- Defined in src/topic_administrator.ts:21
Parameters
- topic: string
Returns Promise<void>

deleteTopic

deleteTopic(topic: string): Promise<void>

- Defined in src/topic_administrator.ts:36
Parameters
- topic: string
Returns Promise<void>

Object literals

Static adminClientConfiguration

adminClientConfiguration: object

retry

retry: object

initialRetryTime

initialRetryTime: number = 300

maxRetryTime

maxRetryTime: number = 500

retries

retries: number = 1

Generated using TypeDoc