kafkad.client

Undocumented in source.

Public Imports

kafkad.config
public import kafkad.config;
Undocumented in source.
kafkad.consumer
public import kafkad.consumer;
Undocumented in source.
kafkad.producer
public import kafkad.producer;
Undocumented in source.
kafkad.exception
public import kafkad.exception;
Undocumented in source.

Members

Classes

Client
class Client

The client acts as a router between brokers, consumers and producers. Consumers and producers connect to the client and it handles connections to the brokers for them. It transparently handles connection failures, leader switches and translates topic/partitions to respective broker connections.

Structs

BrokerAddress
struct BrokerAddress
Undocumented in source.

Meta