Freckle.App.Kafka.Consumer

Documentation

class HasKafkaConsumer env where

Methods

kafkaConsumerL :: Lens' env KafkaConsumer

withKafkaConsumer :: MonadUnliftIO m => KafkaConsumerConfig -> (KafkaConsumer -> m a) -> m a

data KafkaConsumerConfig

Constructors

KafkaConsumerConfig

Fields

• kafkaConsumerConfigBrokerAddresses :: NonEmpty BrokerAddress

  The list of host/port pairs for establishing the initial connection to the Kafka cluster.

  This is the `bootstrap.servers` Kafka consumer configuration property.

• kafkaConsumerConfigGroupId :: ConsumerGroupId

  The consumer group id to which the consumer belongs.

  This is the `group.id` Kafka consumer configuration property.

• kafkaConsumerConfigTopic :: TopicName

  The topic name polled for messages by the Kafka consumer.

• kafkaConsumerConfigOffsetReset :: OffsetReset

  The offset reset parameter used when there is no initial offset in Kafka.

  This is the `auto.offset.reset` Kafka consumer configuration property.

• kafkaConsumerConfigAutoCommitInterval :: Millis

  The interval that offsets are auto-committed to Kafka.

  This sets the `auto.commit.interval.ms` and `enable.auto.commit` Kafka consumer configuration properties.

• kafkaConsumerConfigExtraSubscriptionProps :: Map Text Text

  Extra properties used to configure the Kafka consumer.

Instances

Show KafkaConsumerConfig

Defined in Freckle.App.Kafka.Consumer

Methods

showsPrec :: Int -> KafkaConsumerConfig -> ShowS

show :: KafkaConsumerConfig -> String

showList :: [KafkaConsumerConfig] -> ShowS

envKafkaConsumerConfig :: Parser Error KafkaConsumerConfig

runConsumer :: (MonadMask m, MonadUnliftIO m, MonadReader env m, MonadLogger m, HasKafkaConsumer env, FromJSON a) => Timeout -> (a -> m ()) -> m ()