Hoogle Search

Within LTS Haskell 24.34 (ghc-9.10.3)

Note that Stackage only displays results for the latest LTS and Nightly snapshot. Learn more.

Exact lookup

1. newConsumer :: MonadIO m => ConsumerProperties -> Subscription -> m (Either KafkaError KafkaConsumer)

   hw-kafka-client	Kafka.Consumer

   Create a KafkaConsumer. This consumer must be correctly released using closeConsumer.

2. 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.

3. resumePartitions :: MonadIO m => KafkaConsumer -> [(TopicName, PartitionId)] -> m KafkaError

   hw-kafka-client	Kafka.Consumer

   Resumes specified partitions on the current consumer.

4. 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

5. runConsumer :: ConsumerProperties -> Subscription -> (KafkaConsumer -> IO (Either KafkaError a)) -> IO (Either KafkaError a)

   hw-kafka-client	Kafka.Consumer

   Deprecated: Use newConsumer/closeConsumer instead

6. unConsumerGroupId :: ConsumerGroupId -> Text

   hw-kafka-client	Kafka.Consumer

   No documentation available.

7. module Kafka.Consumer.ConsumerProperties

   Module with consumer properties types and functions.

8. data ConsumerProperties

   hw-kafka-client	Kafka.Consumer.ConsumerProperties

   Properties to create KafkaConsumer.

9. ConsumerProperties :: Map Text Text -> Maybe KafkaLogLevel -> [Callback] -> CallbackPollMode -> ConsumerProperties

   hw-kafka-client	Kafka.Consumer.ConsumerProperties

   No documentation available.

10. newtype ConsumerGroupId

    hw-kafka-client	Kafka.Consumer.Types

    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

Page 214 of many | Previous | Next