Message
Namespace: Kafunk
Parent Module: Protocol
A Kafka message type used for producing and fetching.
Record Fields
| Record Field | Description |
attributes
Signature: Attributes
|
|
crc
Signature: Crc
|
|
key
Signature: ArraySegment<byte>
|
|
magicByte
Signature: MagicByte
|
|
timestamp
Signature: Timestamp
|
|
value
Signature: ArraySegment<byte>
|
|
Constructors
| Constructor | Description |
new(...)
Signature: (crc:Crc * magicByte:MagicByte * attributes:Attributes * ts:Timestamp * key:ArraySegment<byte> * value:ArraySegment<byte>) -> Message
|
CompiledName: |
Static members
| Static member | Description |
Size(_messageVer, m)
Signature: (_messageVer:ApiVersion * m:Message) -> int
|
|
