| Safe Haskell | None |
|---|---|
| Language | Haskell2010 |
Kafka.Internal.Types
- data Error
- data Compression
- data OffsetsTime
- data RequestType
- newtype Topic = Topic ByteString
- newtype Offset = Offset Word64
- newtype Partition = Partition Word32
- newtype Size = Size Word32
- newtype Count = Count Word32
- data Message = Message {}
- newtype MessageSet = MessageSet {
- fromMessageSet :: [ByteString]
Documentation
Different errors returned by Kafka.
Constructors
| UnknownError | Unknown error |
| OffsetOutOfRangeError | Offset requested is invalid or no longer available on the server. |
| InvalidMessageError | A message failed to match its checksum. |
| WrongPartitionError | The requested partition doesn't exist. |
| InvalidFetchSizeError | The maximum size requested for fetching is smaller than the message being fetched. |
data Compression Source
Methods of compression supported by Kafka.
Constructors
| NoCompression | The message is uncompressed. |
| GzipCompression | The message is compressed using |
| SnappyCompression | The message is compressed using |
data OffsetsTime Source
Different times for which offsets may be retrieved using
offsets.
Constructors
| OffsetsLatest | Retrieve the latest offsets |
| OffsetsEarliest | Retrieve the earliest offsets. |
| OffsetsBefore !UTCTime | Retrieve offsets before the given time. Keep in mind that the response will not contain the precise offset that occurred around this time. It will return up to the specified count of offsets in descending, each being the first offset of every segment file for the specified partition with a modified time less than this time, and possibly a "high water mark" for the last segment of the partition (if it was modified before this time) which specifies the offset at which the next message to that partition will be written. |
data RequestType Source
The different request types supported by Kafka.
Represents a Kafka topic.
This is an instance of IsString so a literal string may be used to create
a Topic with the OverloadedStrings extension.
Constructors
| Topic ByteString |
Represents an Offset in Kafka.
This is an instance of Num so a literal number may be used to create an
Offset.
Represents a Kafka topic partition.
This is an instance of Num so a literal number may be used to create a
Partition.
Represents a size.
This is an instance of Num so a literal number may be used to create a
Size.
Represents a Count.
This is an instance of Num so a literal number may be used to create a
Size.
Represents a Message being sent through Kafka.
Constructors
| Message | |
Fields
| |
newtype MessageSet Source
Represents a collection of message payloads.
These are compressed into a single message using Snappy compression when being sent.
Constructors
| MessageSet | |
Fields
| |