Classes

The BrokerConnection is a connection to one specific broker in the Kafka cluster. It owns the NIO Channel with the underlying TCP connecting and offers a high level interface to send messages to the broker.

See more

final public class BrokerConnection : BrokerConnectionProtocol

A client that consumes records from a Kafka cluster. This client transparently handles the failure of Kafka brokers, and transparently adapts as topic partitions it fetches migrate within the cluster. This client also interacts with the broker to allow groups of consumers to load balance consumption using consumer groups.

The consumer maintains TCP connections to the necessary brokers to fetch data.

General

The consumer will transparently handle the failure of servers in the Kafka cluster, and adapt as topic-partitions are created or migrate between brokers. It also interacts with the assigned kafka Group Coordinator node to allow multiple consumers to load balance consumption of topics.

Consumer Groups and Subscriptions

Kafka maintains an offset for each record in a partition.

See more

public class Consumer