kafka library

Apache Kafka client library for Dartlang

This library implements Kafka binary protocol and provides high-level abstractions for producing and consuming messages.

BatchEnvelope: Envelope for message batches used by Consumer.batchConsume.
Broker: Represents single node in a Kafka cluster.
ClusterMetadata: Stores metadata information about cluster including available brokers and topics.
Consumer: High-level Kafka consumer class.
ConsumerGroup
ConsumerOffset: Data structure representing consumer offset.
ContactPoint: Initial contact point with a Kafka cluster.
Fetcher: Message Fetcher.
KafkaServerError: Represents error returned by Kafka server.
KafkaSession: Session responsible for communication with Kafka cluster.
Message: Kafka Message as defined in the protocol.
MessageAttributes: Kafka Message Attributes. Only KafkaCompression is supported by the server at the moment.
MessageEnvelope: Envelope for a Message used by high-level consumer.
OffsetMaster: Master of Offsets.
ProduceEnvelope: Envelope used for publishing messages to Kafka.
Producer: High-level Producer for Kafka.
ProduceResult: Result of producing messages with Producer.
TopicMetadata: Represents Kafka TopicMetadata data structure returned in MetadataResponse.
TopicOffset: Represents an offset of particular topic and partition.
TopicPartition

KafkaCompression: Compression types supported by Kafka.
OffsetOutOfRangeBehavior: Determines behavior of Consumer when it receives OffsetOutOfRange API error.

dartKafkaId → const String: String identifier used to pass to Kafka server in API calls.

MessageCrcMismatchError: Used to indicate there is a mismatch in CRC sum of a message (message is corrupted).
ProduceError: Exception thrown in case when server returned errors in response to Producer.produce().