Interface FluvioClient

interface FluvioClient {
    admin(): Promise<FluvioAdmin>;
    connect(options?): Promise<FluvioClient>;
    partitionConsumer(topic, partition): Promise<PartitionConsumer>;
    topicProducer(topic): Promise<TopicProducer>;
}

Implemented by

Methods

Generated using TypeDoc