kafka library
Apache Kafka client library for Dartlang
This library implements Kafka binary protocol and provides high-level abstractions for producing and consuming messages.
Classes
- 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
Enums
- KafkaCompression
- Compression types supported by Kafka.
- OffsetOutOfRangeBehavior
-
Determines behavior of Consumer when it receives
OffsetOutOfRangeAPI error.
Extensions
Constants
- dartKafkaId → const String
- String identifier used to pass to Kafka server in API calls.
Exceptions / Errors
- 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().