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.

Exact lookup

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

   hw-kafka-client	Kafka.Consumer

   Deprecated: Use newConsumer/closeConsumer instead

2. unConsumerGroupId :: ConsumerGroupId -> Text

   hw-kafka-client	Kafka.Consumer

   No documentation available.

3. module Kafka.Consumer.ConsumerProperties

   Module with consumer properties types and functions.

4. data ConsumerProperties

   hw-kafka-client	Kafka.Consumer.ConsumerProperties

   Properties to create KafkaConsumer.

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

   hw-kafka-client	Kafka.Consumer.ConsumerProperties

   No documentation available.

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

7. ConsumerGroupId :: Text -> ConsumerGroupId

   hw-kafka-client	Kafka.Consumer.Types

   No documentation available.

8. data ConsumerRecord k v

   hw-kafka-client	Kafka.Consumer.Types

   Represents a received message from Kafka (i.e. used in a consumer)

9. ConsumerRecord :: TopicName -> PartitionId -> Offset -> Timestamp -> Headers -> k -> v -> ConsumerRecord k v

   hw-kafka-client	Kafka.Consumer.Types

   No documentation available.

10. data KafkaConsumer

    hw-kafka-client	Kafka.Consumer.Types

    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.

Page 216 of many | Previous | Next