common library
Common dependencies for other Kafka libraries withing this package.
Classes
- Broker
- Represents single node in a Kafka cluster.
- ConsumerOffset
- Data structure representing consumer offset.
- KafkaServerError
- Represents error returned by Kafka server.
- Message
- Kafka Message as defined in the protocol.
- MessageAttributes
- Kafka Message Attributes. Only KafkaCompression is supported by the server at the moment.
- ProduceEnvelope
- Envelope used for publishing messages to Kafka.
- TopicPartition
Enums
- KafkaCompression
- Compression types supported by Kafka.
Constants
- dartKafkaId → const String
- String identifier used to pass to Kafka server in API calls.
Properties
- kafkaLogger → Logger
-
Logger for this library.
final
Exceptions / Errors
- MessageCrcMismatchError
- Used to indicate there is a mismatch in CRC sum of a message (message is corrupted).