Effectful.hs

module Kafka.Effectful (
    -- * Producer Effect
    KafkaProducer,
    runKafkaProducer,
    produceMessage,
    produceMessageSync,
    produceMessageBatch,
    flushProducer,

    -- ** Transactions
    initTransactions,
    beginTransaction,
    commitTransaction,
    abortTransaction,
    commitOffsetMessageTransaction,
    TxError,
    getKafkaError,
    kafkaErrorIsFatal,
    kafkaErrorIsRetriable,
    kafkaErrorTxnRequiresAbort,

    -- * Consumer Effect
    KafkaConsumer,
    runKafkaConsumer,

    -- ** Polling
    pollMessage,
    pollMessageBatch,

    -- ** Offset Management
    commitOffsetMessage,
    commitAllOffsets,
    commitPartitionsOffsets,
    storeOffsets,
    storeOffsetMessage,

    -- ** Partition Management
    assign,
    pausePartitions,
    resumePartitions,
    seekPartitions,

    -- ** Querying
    committed,
    position,
    assignment,
    subscription,

    -- * Producer Types
    ProducerRecord (..),
    ProducePartition (..),
    DeliveryReport (..),
    ImmediateError (..),
    ProducerProperties (..),

    -- * Consumer Types
    ConsumerRecord (..),
    ConsumerProperties (..),
    CallbackPollMode (..),
    Subscription (..),
    Offset (..),
    OffsetReset (..),
    OffsetCommit (..),
    TopicPartition (..),
    SubscribedPartitions (..),
    ConsumerGroupId (..),
    PartitionOffset (..),
    Timestamp (..),
    RebalanceEvent (..),

    -- * Subscription Builders
    topics,
    offsetReset,
    extraSubscriptionProps,

    -- * Common Types
    KafkaError (..),
    TopicName (..),
    BrokerAddress (..),
    Timeout (..),
    BatchSize (..),
    PartitionId (..),
    Millis (..),
    ClientId (..),
    KafkaLogLevel (..),
    KafkaDebug (..),
    KafkaCompressionCodec (..),
    Headers,
    headersFromList,
    headersToList,
)
where

import Kafka.Effectful.Consumer (
    CallbackPollMode (..),
    ConsumerGroupId (..),
    ConsumerProperties (..),
    ConsumerRecord (..),
    KafkaConsumer,
    Offset (..),
    OffsetCommit (..),
    OffsetReset (..),
    PartitionOffset (..),
    RebalanceEvent (..),
    SubscribedPartitions (..),
    Subscription (..),
    Timestamp (..),
    TopicPartition (..),
    assign,
    assignment,
    commitAllOffsets,
    commitOffsetMessage,
    commitPartitionsOffsets,
    committed,
    extraSubscriptionProps,
    offsetReset,
    pausePartitions,
    pollMessage,
    pollMessageBatch,
    position,
    resumePartitions,
    runKafkaConsumer,
    seekPartitions,
    storeOffsetMessage,
    storeOffsets,
    subscription,
    topics,
 )
import Kafka.Effectful.Producer (
    DeliveryReport (..),
    ImmediateError (..),
    KafkaProducer,
    ProducePartition (..),
    ProducerProperties (..),
    ProducerRecord (..),
    TxError,
    abortTransaction,
    beginTransaction,
    commitOffsetMessageTransaction,
    commitTransaction,
    flushProducer,
    getKafkaError,
    initTransactions,
    kafkaErrorIsFatal,
    kafkaErrorIsRetriable,
    kafkaErrorTxnRequiresAbort,
    produceMessage,
    produceMessageBatch,
    produceMessageSync,
    runKafkaProducer,
 )
import Kafka.Types (
    BatchSize (..),
    BrokerAddress (..),
    ClientId (..),
    Headers,
    KafkaCompressionCodec (..),
    KafkaDebug (..),
    KafkaError (..),
    KafkaLogLevel (..),
    Millis (..),
    PartitionId (..),
    Timeout (..),
    TopicName (..),
    headersFromList,
    headersToList,
 )