MessageAttributes class

Kafka Message Attributes. Only KafkaCompression is supported by the server at the moment.

Constructors

MessageAttributes.new([KafkaCompression compression = KafkaCompression.none])
Creates new instance of MessageAttributes.
MessageAttributes.fromByte(int byte)
Creates MessageAttributes from the raw byte.

Properties

compression KafkaCompression
Compression codec.
final
hashCode int
The hash code for this object.
no setterinherited
runtimeType Type
A representation of the runtime type of the object.
no setterinherited

Methods

noSuchMethod(Invocation invocation) → dynamic
Invoked when a nonexistent method or property is accessed.
inherited
toInt() int
Converts this attributes into byte.
toString() String
A string representation of this object.
inherited

Operators

operator ==(Object other) bool
The equality operator.
inherited

Static Methods

getCompression(int byte) KafkaCompression