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

Defined in Kafka.Producer.Types

Methods

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

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

Show ProducerRecord

Defined in Kafka.Producer.Types

Methods

showsPrec :: Int -> ProducerRecord -> ShowS

show :: ProducerRecord -> String

showList :: [ProducerRecord] -> ShowS

Generic ProducerRecord

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

Defined in Kafka.Producer.Types

type Rep ProducerRecord = D1 (MetaData "ProducerRecord" "Kafka.Producer.Types" "hw-kafka-client-3.1.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

Constructors

SpecifiedPartition !Int

UnassignedPartition

Instances

Eq ProducePartition

Defined in Kafka.Producer.Types

Methods

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

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

Ord ProducePartition

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

Defined in Kafka.Producer.Types

Methods

showsPrec :: Int -> ProducePartition -> ShowS

show :: ProducePartition -> String

showList :: [ProducePartition] -> ShowS

Generic ProducePartition

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

Defined in Kafka.Producer.Types

type Rep ProducePartition = D1 (MetaData "ProducePartition" "Kafka.Producer.Types" "hw-kafka-client-3.1.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

Constructors

DeliverySuccess ProducerRecord Offset

DeliveryFailure ProducerRecord KafkaError

NoMessageError KafkaError

Instances

Eq DeliveryReport

Defined in Kafka.Producer.Types

Methods

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

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

Show DeliveryReport

Defined in Kafka.Producer.Types

Methods

showsPrec :: Int -> DeliveryReport -> ShowS

show :: DeliveryReport -> String

showList :: [DeliveryReport] -> ShowS

Generic DeliveryReport

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

Defined in Kafka.Producer.Types

type Rep DeliveryReport = D1 (MetaData "DeliveryReport" "Kafka.Producer.Types" "hw-kafka-client-3.1.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))))

newtype ImmediateError

Data type representing an error that is caused by pre-flight conditions not being met

Constructors

ImmediateError KafkaError

Instances

Eq ImmediateError

Defined in Kafka.Producer.Types

Methods

(==) :: ImmediateError -> ImmediateError -> Bool

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

Show ImmediateError

Defined in Kafka.Producer.Types

Methods

showsPrec :: Int -> ImmediateError -> ShowS

show :: ImmediateError -> String

showList :: [ImmediateError] -> ShowS