Safe Haskell	None
Language	Haskell2010

Kafka.Producer.Types

Synopsis

data KafkaProducer = KafkaProducer {
- kpKafkaPtr :: !Kafka
- kpKafkaConf :: !KafkaConf
- kpTopicConf :: !TopicConf
}
data ProducerRecord = ProducerRecord {
- prTopic :: !TopicName
- prPartition :: !ProducePartition
- prKey :: Maybe ByteString
- prValue :: Maybe ByteString
}
data ProducePartition
- = SpecifiedPartition !Int
- | UnassignedPartition
data DeliveryReport

Documentation

data KafkaProducer Source #

Main pointer to Kafka object, which contains our brokers

Constructors

KafkaProducer
Fields kpKafkaPtr :: !Kafka kpKafkaConf :: !KafkaConf kpTopicConf :: !TopicConf

data ProducerRecord Source #

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 Source #
Instance details Defined in Kafka.Producer.Types Methods (==) :: ProducerRecord -> ProducerRecord -> Bool # (/=) :: ProducerRecord -> ProducerRecord -> Bool #
Show ProducerRecord Source #
Instance details Defined in Kafka.Producer.Types Methods showsPrec :: Int -> ProducerRecord -> ShowS # show :: ProducerRecord -> String # showList :: [ProducerRecord] -> ShowS #
Generic ProducerRecord Source #
Instance details Defined in Kafka.Producer.Types Associated Types type Rep ProducerRecord :: Type -> Type # Methods from :: ProducerRecord -> Rep ProducerRecord x # to :: Rep ProducerRecord x -> ProducerRecord #
type Rep ProducerRecord Source #
Instance details Defined in Kafka.Producer.Types type Rep ProducerRecord = D1 (MetaData "ProducerRecord" "Kafka.Producer.Types" "hw-kafka-client-3.0.0-inplace" False) (C1 (MetaCons "ProducerRecord" PrefixI True) ((S1 (MetaSel (Just "prTopic") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 TopicName) :: S1 (MetaSel (Just "prPartition") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 ProducePartition)) :: (S1 (MetaSel (Just "prKey") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 (Maybe ByteString)) :*: S1 (MetaSel (Just "prValue") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 (Maybe ByteString)))))

data ProducePartition Source #

Constructors

SpecifiedPartition !Int
UnassignedPartition

Instances

Eq ProducePartition Source #
Instance details Defined in Kafka.Producer.Types Methods (==) :: ProducePartition -> ProducePartition -> Bool # (/=) :: ProducePartition -> ProducePartition -> Bool #
Ord ProducePartition Source #
Instance details Defined in Kafka.Producer.Types 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 Source #
Instance details Defined in Kafka.Producer.Types Methods showsPrec :: Int -> ProducePartition -> ShowS # show :: ProducePartition -> String # showList :: [ProducePartition] -> ShowS #
Generic ProducePartition Source #
Instance details Defined in Kafka.Producer.Types Associated Types type Rep ProducePartition :: Type -> Type # Methods from :: ProducePartition -> Rep ProducePartition x # to :: Rep ProducePartition x -> ProducePartition #
type Rep ProducePartition Source #
Instance details Defined in Kafka.Producer.Types type Rep ProducePartition = D1 (MetaData "ProducePartition" "Kafka.Producer.Types" "hw-kafka-client-3.0.0-inplace" False) (C1 (MetaCons "SpecifiedPartition" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) SourceUnpack SourceStrict DecidedStrict) (Rec0 Int)) :+: C1 (MetaCons "UnassignedPartition" PrefixI False) (U1 :: Type -> Type))

data DeliveryReport Source #

Constructors

DeliverySuccess ProducerRecord Offset
DeliveryFailure ProducerRecord KafkaError
NoMessageError KafkaError

Instances

Eq DeliveryReport Source #
Instance details Defined in Kafka.Producer.Types Methods (==) :: DeliveryReport -> DeliveryReport -> Bool # (/=) :: DeliveryReport -> DeliveryReport -> Bool #
Show DeliveryReport Source #
Instance details Defined in Kafka.Producer.Types Methods showsPrec :: Int -> DeliveryReport -> ShowS # show :: DeliveryReport -> String # showList :: [DeliveryReport] -> ShowS #
Generic DeliveryReport Source #
Instance details Defined in Kafka.Producer.Types Associated Types type Rep DeliveryReport :: Type -> Type # Methods from :: DeliveryReport -> Rep DeliveryReport x # to :: Rep DeliveryReport x -> DeliveryReport #
type Rep DeliveryReport Source #
Instance details Defined in Kafka.Producer.Types type Rep DeliveryReport = D1 (MetaData "DeliveryReport" "Kafka.Producer.Types" "hw-kafka-client-3.0.0-inplace" False) (C1 (MetaCons "DeliverySuccess" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 ProducerRecord) :: S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Offset)) :+: (C1 (MetaCons "DeliveryFailure" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 ProducerRecord) :: S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 KafkaError)) :+: C1 (MetaCons "NoMessageError" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 KafkaError))))