Kafka.Produce.Response.V9

Documentation

data Response

Constructors

Response

Fields

• topics :: !(SmallArray Topic)
• throttleTimeMilliseconds :: !Int32
• taggedFields :: !(SmallArray TaggedField)

Instances

Show Response

Defined in Kafka.Produce.Response.V9

Methods

showsPrec :: Int -> Response -> ShowS

show :: Response -> String

showList :: [Response] -> ShowS

data Topic

Constructors

Topic

Fields

• name :: !Text
• partitions :: !(SmallArray Partition)
• taggedFields :: !(SmallArray TaggedField)

Instances

Show Topic

Defined in Kafka.Produce.Response.V9

Methods

showsPrec :: Int -> Topic -> ShowS

show :: Topic -> String

showList :: [Topic] -> ShowS

data Partition

Constructors

Partition

Fields

• index :: !Int32
• errorCode :: !ErrorCode
• baseOffset :: !Int64
• logAppendTimeMilliseconds :: !Int64
• logStartOffset :: !Int64
• errors :: !(SmallArray Error)
• errorMessage :: !Text

  Kafka documentation describes this as: "The global error message summarizing the common root cause of the records that caused the batch to be dropped". Although kafka allows both NULL and the empty string as distinct values, we decode NULL by mapping it to the empty string.

• taggedFields :: !(SmallArray TaggedField)

Instances

Show Partition

Defined in Kafka.Produce.Response.V9

Methods

showsPrec :: Int -> Partition -> ShowS

show :: Partition -> String

showList :: [Partition] -> ShowS

data Error

Constructors

Error

Fields

• index :: !Int32
• message :: !Text
• taggedFields :: !(SmallArray TaggedField)

Instances

Show Error

Defined in Kafka.Produce.Response.V9

Methods

showsPrec :: Int -> Error -> ShowS

show :: Error -> String

showList :: [Error] -> ShowS

parser :: Context -> Parser Context s Response

decode :: Bytes -> Either Context Response

decodeHeaded :: Bytes -> Either Context (Headed Response)