Kafka.Consumer.Subscription

Documentation

data Subscription

Constructors

Subscription [TopicName] (Map String String)

Instances

Monoid Subscription

Methods

mempty :: Subscription

mappend :: Subscription -> Subscription -> Subscription

mconcat :: [Subscription] -> Subscription

topics :: [TopicName] -> Subscription

offsetReset :: OffsetReset -> Subscription

autoCommit :: Millis -> Subscription

extraSubscriptionProps :: Map String String -> Subscription