Kafka.Producer.Types

Documentation

data KafkaProducer

Main pointer to Kafka object, which contains our brokers

Constructors

KafkaProducer

Fields

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

Instances

Show KafkaProducer

Methods

showsPrec :: Int -> KafkaProducer -> ShowS

show :: KafkaProducer -> String

showList :: [KafkaProducer] -> ShowS

HasKafkaConf KafkaProducer

Methods

getKafkaConf :: KafkaProducer -> KafkaConf

HasKafka KafkaProducer

Methods

getKafka :: KafkaProducer -> Kafka

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