hw-kafka-client-4.0.0: Kafka bindings for Haskell

Safe HaskellNone
LanguageHaskell2010

Kafka.Producer.Types

Description

Module holding producer types.

Synopsis

Documentation

data KafkaProducer Source #

The main type for Kafka message production, used e.g. to send messages.

Its constructor is intentionally not exposed, instead, one should used newProducer to acquire such a value.

Constructors

KafkaProducer 

Fields

data ProducerRecord Source #

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

data ProducePartition Source #

 

Constructors

SpecifiedPartition !Int

The partition number of the topic

UnassignedPartition

Let the Kafka broker decide the partition

Instances
Eq ProducePartition Source # 
Instance details

Defined in Kafka.Producer.Types

Ord ProducePartition Source # 
Instance details

Defined in Kafka.Producer.Types

Show ProducePartition Source # 
Instance details

Defined in Kafka.Producer.Types

Generic ProducePartition Source # 
Instance details

Defined in Kafka.Producer.Types

Associated Types

type Rep ProducePartition :: Type -> Type #

type Rep ProducePartition Source # 
Instance details

Defined in Kafka.Producer.Types

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

The result of sending a message to the broker, useful for callbacks

Constructors

DeliverySuccess ProducerRecord Offset

The message was successfully sent at this offset

DeliveryFailure ProducerRecord KafkaError

The message could not be sent

NoMessageError KafkaError

An error occurred, but librdkafka did not attach any sent message

Instances
Eq DeliveryReport Source # 
Instance details

Defined in Kafka.Producer.Types

Show DeliveryReport Source # 
Instance details

Defined in Kafka.Producer.Types

Generic DeliveryReport Source # 
Instance details

Defined in Kafka.Producer.Types

Associated Types

type Rep DeliveryReport :: Type -> Type #

type Rep DeliveryReport Source # 
Instance details

Defined in Kafka.Producer.Types

newtype ImmediateError Source #

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