Kafka.Producer.Types

Documentation

data KafkaProducer

Main pointer to Kafka object, which contains our brokers

Constructors

KafkaProducer

Fields

• kpKafkaPtr :: !Kafka
• kpKafkaConf :: !KafkaConf
• kpTopicConf :: !TopicConf

data ProducerRecord

Represents messages to be enqueued onto a Kafka broker (i.e. used for a producer)

Constructors

ProducerRecord

Fields

• prTopic :: !TopicName
• prPartition :: !ProducePartition
• prKey :: Maybe ByteString
• prValue :: Maybe ByteString

Instances

Eq ProducerRecord

Methods

(==) :: ProducerRecord -> ProducerRecord -> Bool

(/=) :: ProducerRecord -> ProducerRecord -> Bool

Show ProducerRecord

Methods

showsPrec :: Int -> ProducerRecord -> ShowS

show :: ProducerRecord -> String

showList :: [ProducerRecord] -> ShowS

data ProducePartition

Constructors

SpecifiedPartition !Int

UnassignedPartition

Instances

Eq ProducePartition

Methods

(==) :: ProducePartition -> ProducePartition -> Bool

(/=) :: ProducePartition -> ProducePartition -> Bool

Ord ProducePartition

Methods

compare :: ProducePartition -> ProducePartition -> Ordering

(<) :: ProducePartition -> ProducePartition -> Bool

(<=) :: ProducePartition -> ProducePartition -> Bool

(>) :: ProducePartition -> ProducePartition -> Bool

(>=) :: ProducePartition -> ProducePartition -> Bool

max :: ProducePartition -> ProducePartition -> ProducePartition

min :: ProducePartition -> ProducePartition -> ProducePartition

Show ProducePartition

Methods

showsPrec :: Int -> ProducePartition -> ShowS

show :: ProducePartition -> String

showList :: [ProducePartition] -> ShowS

data DeliveryReport

Constructors

DeliverySuccess ProducerRecord Offset

DeliveryFailure ProducerRecord KafkaError

NoMessageError KafkaError

Instances

Eq DeliveryReport

Methods

(==) :: DeliveryReport -> DeliveryReport -> Bool

(/=) :: DeliveryReport -> DeliveryReport -> Bool

Show DeliveryReport

Methods

showsPrec :: Int -> DeliveryReport -> ShowS

show :: DeliveryReport -> String

showList :: [DeliveryReport] -> ShowS