Consumer.hs

module Kafka.Effectful.Consumer (
    -- * Effect
    KafkaConsumer,

    -- * Interpreter
    runKafkaConsumer,

    -- * Polling
    pollMessage,
    pollMessageBatch,

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

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

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

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

    -- * Configuration
    ConsumerProperties (..),
    CallbackPollMode (..),
    K.brokersList,
    K.autoCommit,
    K.noAutoCommit,
    K.noAutoOffsetStore,
    K.groupId,
    K.clientId,
    K.setCallback,
    K.logLevel,
    K.compression,
    K.suppressDisconnectLogs,
    K.statisticsInterval,
    K.extraProps,
    K.extraProp,
    K.debugOptions,
    K.queuedMaxMessagesKBytes,
    K.callbackPollMode,

    -- * Subscription
    Subscription (..),
    topics,
    offsetReset,
    extraSubscriptionProps,

    -- * Callbacks
    K.rebalanceCallback,
    K.offsetCommitCallback,
    K.errorCallback,
    K.logCallback,
    K.statsCallback,
    K.Callback,

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

import Kafka.Consumer.ConsumerProperties (CallbackPollMode (..), ConsumerProperties (..))
import Kafka.Consumer.ConsumerProperties qualified as K
import Kafka.Consumer.Subscription (Subscription (..), extraSubscriptionProps, offsetReset, topics)
import Kafka.Consumer.Types (ConsumerGroupId (..), ConsumerRecord (..), Offset (..), OffsetCommit (..), OffsetReset (..), PartitionOffset (..), RebalanceEvent (..), SubscribedPartitions (..), Timestamp (..), TopicPartition (..))
import Kafka.Effectful.Consumer.Effect (KafkaConsumer, assign, assignment, commitAllOffsets, commitOffsetMessage, commitPartitionsOffsets, committed, pausePartitions, pollMessage, pollMessageBatch, position, resumePartitions, seekPartitions, storeOffsetMessage, storeOffsets, subscription)
import Kafka.Effectful.Consumer.Interpreter (runKafkaConsumer)
import Kafka.Types (BatchSize (..), BrokerAddress (..), ClientId (..), Headers, KafkaCompressionCodec (..), KafkaDebug (..), KafkaError (..), KafkaLogLevel (..), Millis (..), PartitionId (..), Timeout (..), TopicName (..), headersFromList, headersToList)