Hoogle Search
Within LTS Haskell 24.50 (ghc-9.10.3)
Note that Stackage only displays results for the latest LTS and Nightly snapshot. Learn more.
-
hw-kafka-client Kafka.Consumer Consumer group ID. Different consumers with the same consumer group ID will get assigned different partitions of each subscribed topic. See Kafka documentation on consumer group
ConsumerGroupId :: Text -> ConsumerGroupIdhw-kafka-client Kafka.Consumer No documentation available.
-
hw-kafka-client Kafka.Consumer Represents a received message from Kafka (i.e. used in a consumer)
-
hw-kafka-client Kafka.Consumer No documentation available.
-
hw-kafka-client Kafka.Consumer The main type for Kafka consumption, used e.g. to poll and commit messages. Its constructor is intentionally not exposed, instead, one should use newConsumer to acquire such a value.
closeConsumer :: MonadIO m => KafkaConsumer -> m (Maybe KafkaError)hw-kafka-client Kafka.Consumer Closes the consumer. See newConsumer
-
hw-kafka-client Kafka.Consumer Create a KafkaConsumer. This consumer must be correctly released using closeConsumer.
pollConsumerEvents :: KafkaConsumer -> Maybe Timeout -> IO ()hw-kafka-client Kafka.Consumer Polls the provided kafka consumer for events. Events will cause application provided callbacks to be called. The Timeout argument specifies the maximum amount of time (in milliseconds) that the call will block waiting for events. This function is called on each pollMessage and, if runtime allows multi threading, it is called periodically in a separate thread to ensure the callbacks are handled ASAP. There is no particular need to call this function manually unless some special cases in a single-threaded environment when polling for events on each pollMessage is not frequent enough.
resumePartitions :: MonadIO m => KafkaConsumer -> [(TopicName, PartitionId)] -> m KafkaErrorhw-kafka-client Kafka.Consumer Resumes specified partitions on the current consumer.
rewindConsumer :: MonadIO m => KafkaConsumer -> Timeout -> m (Maybe KafkaError)hw-kafka-client Kafka.Consumer Rewind consumer's consume position to the last committed offsets for the current assignment. NOTE: follows https://github.com/edenhill/librdkafka/blob/master/examples/transactions.c#L166