Kafka.Consumer.Types

Module holding consumer types.

Documentation

data KafkaConsumer

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.

Constructors

KafkaConsumer

Fields

• kcKafkaPtr :: !Kafka
• kcKafkaConf :: !KafkaConf

newtype ConsumerGroupId

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

Constructors

ConsumerGroupId

Fields

• unConsumerGroupId :: Text

Instances

Eq ConsumerGroupId

Defined in Kafka.Consumer.Types

Methods

(==) :: ConsumerGroupId -> ConsumerGroupId -> Bool

(/=) :: ConsumerGroupId -> ConsumerGroupId -> Bool

Ord ConsumerGroupId

Defined in Kafka.Consumer.Types

Methods

compare :: ConsumerGroupId -> ConsumerGroupId -> Ordering

(<) :: ConsumerGroupId -> ConsumerGroupId -> Bool

(<=) :: ConsumerGroupId -> ConsumerGroupId -> Bool

(>) :: ConsumerGroupId -> ConsumerGroupId -> Bool

(>=) :: ConsumerGroupId -> ConsumerGroupId -> Bool

max :: ConsumerGroupId -> ConsumerGroupId -> ConsumerGroupId

min :: ConsumerGroupId -> ConsumerGroupId -> ConsumerGroupId

Show ConsumerGroupId

Defined in Kafka.Consumer.Types

Methods

showsPrec :: Int -> ConsumerGroupId -> ShowS

show :: ConsumerGroupId -> String

showList :: [ConsumerGroupId] -> ShowS

IsString ConsumerGroupId

Defined in Kafka.Consumer.Types

Methods

fromString :: String -> ConsumerGroupId

Generic ConsumerGroupId

Defined in Kafka.Consumer.Types

Associated Types

type Rep ConsumerGroupId :: Type -> Type

Methods

from :: ConsumerGroupId -> Rep ConsumerGroupId x

to :: Rep ConsumerGroupId x -> ConsumerGroupId

type Rep ConsumerGroupId

Defined in Kafka.Consumer.Types

type Rep ConsumerGroupId = D1 (MetaData "ConsumerGroupId" "Kafka.Consumer.Types" "hw-kafka-client-4.0.2-inplace" True) (C1 (MetaCons "ConsumerGroupId" PrefixI True) (S1 (MetaSel (Just "unConsumerGroupId") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Text)))

newtype Offset

A message offset in a partition

Constructors

Offset

Fields

• unOffset :: Int64

Instances

Eq Offset

Defined in Kafka.Consumer.Types

Methods

(==) :: Offset -> Offset -> Bool

(/=) :: Offset -> Offset -> Bool

Ord Offset

Defined in Kafka.Consumer.Types

Methods

compare :: Offset -> Offset -> Ordering

(<) :: Offset -> Offset -> Bool

(<=) :: Offset -> Offset -> Bool

(>) :: Offset -> Offset -> Bool

(>=) :: Offset -> Offset -> Bool

max :: Offset -> Offset -> Offset

min :: Offset -> Offset -> Offset

Read Offset

Defined in Kafka.Consumer.Types

Methods

readsPrec :: Int -> ReadS Offset

readList :: ReadS [Offset]

readPrec :: ReadPrec Offset

readListPrec :: ReadPrec [Offset]

Show Offset

Defined in Kafka.Consumer.Types

Methods

showsPrec :: Int -> Offset -> ShowS

show :: Offset -> String

showList :: [Offset] -> ShowS

Generic Offset

Defined in Kafka.Consumer.Types

Associated Types

type Rep Offset :: Type -> Type

Methods

from :: Offset -> Rep Offset x

to :: Rep Offset x -> Offset

type Rep Offset

Defined in Kafka.Consumer.Types

type Rep Offset = D1 (MetaData "Offset" "Kafka.Consumer.Types" "hw-kafka-client-4.0.2-inplace" True) (C1 (MetaCons "Offset" PrefixI True) (S1 (MetaSel (Just "unOffset") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Int64)))

data OffsetReset

Where to reset the offset when there is no initial offset in Kafka

See Kafka documentation on offset reset

Constructors

Earliest

Latest

Instances

Eq OffsetReset

Defined in Kafka.Consumer.Types

Methods

(==) :: OffsetReset -> OffsetReset -> Bool

(/=) :: OffsetReset -> OffsetReset -> Bool

Show OffsetReset

Defined in Kafka.Consumer.Types

Methods

showsPrec :: Int -> OffsetReset -> ShowS

show :: OffsetReset -> String

showList :: [OffsetReset] -> ShowS

Generic OffsetReset

Defined in Kafka.Consumer.Types

Associated Types

type Rep OffsetReset :: Type -> Type

Methods

from :: OffsetReset -> Rep OffsetReset x

to :: Rep OffsetReset x -> OffsetReset

type Rep OffsetReset

Defined in Kafka.Consumer.Types

type Rep OffsetReset = D1 (MetaData "OffsetReset" "Kafka.Consumer.Types" "hw-kafka-client-4.0.2-inplace" False) (C1 (MetaCons "Earliest" PrefixI False) (U1 :: Type -> Type) :+: C1 (MetaCons "Latest" PrefixI False) (U1 :: Type -> Type))

data RebalanceEvent

A set of events which happen during the rebalancing process

Constructors

RebalanceBeforeAssign [(TopicName, PartitionId)]

Happens before Kafka Client confirms new assignment

RebalanceAssign [(TopicName, PartitionId)]

Happens after the new assignment is confirmed

RebalanceBeforeRevoke [(TopicName, PartitionId)]

Happens before Kafka Client confirms partitions rejection

RebalanceRevoke [(TopicName, PartitionId)]

Happens after the rejection is confirmed

Instances

Eq RebalanceEvent

Defined in Kafka.Consumer.Types

Methods

(==) :: RebalanceEvent -> RebalanceEvent -> Bool

(/=) :: RebalanceEvent -> RebalanceEvent -> Bool

Show RebalanceEvent

Defined in Kafka.Consumer.Types

Methods

showsPrec :: Int -> RebalanceEvent -> ShowS

show :: RebalanceEvent -> String

showList :: [RebalanceEvent] -> ShowS

Generic RebalanceEvent

Defined in Kafka.Consumer.Types

Associated Types

type Rep RebalanceEvent :: Type -> Type

Methods

from :: RebalanceEvent -> Rep RebalanceEvent x

to :: Rep RebalanceEvent x -> RebalanceEvent

type Rep RebalanceEvent

Defined in Kafka.Consumer.Types

type Rep RebalanceEvent = D1 (MetaData "RebalanceEvent" "Kafka.Consumer.Types" "hw-kafka-client-4.0.2-inplace" False) ((C1 (MetaCons "RebalanceBeforeAssign" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 [(TopicName, PartitionId)])) :+: C1 (MetaCons "RebalanceAssign" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 [(TopicName, PartitionId)]))) :+: (C1 (MetaCons "RebalanceBeforeRevoke" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 [(TopicName, PartitionId)])) :+: C1 (MetaCons "RebalanceRevoke" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 [(TopicName, PartitionId)]))))

data PartitionOffset

The partition offset

Constructors

PartitionOffsetBeginning

PartitionOffsetEnd

PartitionOffset Int64

PartitionOffsetStored

PartitionOffsetInvalid

Instances

Eq PartitionOffset

Defined in Kafka.Consumer.Types

Methods

(==) :: PartitionOffset -> PartitionOffset -> Bool

(/=) :: PartitionOffset -> PartitionOffset -> Bool

Show PartitionOffset

Defined in Kafka.Consumer.Types

Methods

showsPrec :: Int -> PartitionOffset -> ShowS

show :: PartitionOffset -> String

showList :: [PartitionOffset] -> ShowS

Generic PartitionOffset

Defined in Kafka.Consumer.Types

Associated Types

type Rep PartitionOffset :: Type -> Type

Methods

from :: PartitionOffset -> Rep PartitionOffset x

to :: Rep PartitionOffset x -> PartitionOffset

type Rep PartitionOffset

Defined in Kafka.Consumer.Types

type Rep PartitionOffset = D1 (MetaData "PartitionOffset" "Kafka.Consumer.Types" "hw-kafka-client-4.0.2-inplace" False) ((C1 (MetaCons "PartitionOffsetBeginning" PrefixI False) (U1 :: Type -> Type) :+: C1 (MetaCons "PartitionOffsetEnd" PrefixI False) (U1 :: Type -> Type)) :+: (C1 (MetaCons "PartitionOffset" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Int64)) :+: (C1 (MetaCons "PartitionOffsetStored" PrefixI False) (U1 :: Type -> Type) :+: C1 (MetaCons "PartitionOffsetInvalid" PrefixI False) (U1 :: Type -> Type))))

data SubscribedPartitions

Partitions subscribed by a consumer

Constructors

SubscribedPartitions [PartitionId]

Subscribe only to those partitions

SubscribedPartitionsAll

Subscribe to all partitions

Instances

Eq SubscribedPartitions

Defined in Kafka.Consumer.Types

Methods

(==) :: SubscribedPartitions -> SubscribedPartitions -> Bool

(/=) :: SubscribedPartitions -> SubscribedPartitions -> Bool

Show SubscribedPartitions

Defined in Kafka.Consumer.Types

Methods

showsPrec :: Int -> SubscribedPartitions -> ShowS

show :: SubscribedPartitions -> String

showList :: [SubscribedPartitions] -> ShowS

Generic SubscribedPartitions

Defined in Kafka.Consumer.Types

Associated Types

type Rep SubscribedPartitions :: Type -> Type

Methods

from :: SubscribedPartitions -> Rep SubscribedPartitions x

to :: Rep SubscribedPartitions x -> SubscribedPartitions

type Rep SubscribedPartitions

Defined in Kafka.Consumer.Types

type Rep SubscribedPartitions = D1 (MetaData "SubscribedPartitions" "Kafka.Consumer.Types" "hw-kafka-client-4.0.2-inplace" False) (C1 (MetaCons "SubscribedPartitions" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 [PartitionId])) :+: C1 (MetaCons "SubscribedPartitionsAll" PrefixI False) (U1 :: Type -> Type))

data Timestamp

Consumer record timestamp

Constructors

CreateTime !Millis

LogAppendTime !Millis

NoTimestamp

Instances

Eq Timestamp

Defined in Kafka.Consumer.Types

Methods

(==) :: Timestamp -> Timestamp -> Bool

(/=) :: Timestamp -> Timestamp -> Bool

Read Timestamp

Defined in Kafka.Consumer.Types

Methods

readsPrec :: Int -> ReadS Timestamp

readList :: ReadS [Timestamp]

readPrec :: ReadPrec Timestamp

readListPrec :: ReadPrec [Timestamp]

Show Timestamp

Defined in Kafka.Consumer.Types

Methods

showsPrec :: Int -> Timestamp -> ShowS

show :: Timestamp -> String

showList :: [Timestamp] -> ShowS

Generic Timestamp

Defined in Kafka.Consumer.Types

Associated Types

type Rep Timestamp :: Type -> Type

Methods

from :: Timestamp -> Rep Timestamp x

to :: Rep Timestamp x -> Timestamp

type Rep Timestamp

Defined in Kafka.Consumer.Types

type Rep Timestamp = D1 (MetaData "Timestamp" "Kafka.Consumer.Types" "hw-kafka-client-4.0.2-inplace" False) (C1 (MetaCons "CreateTime" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 Millis)) :+: (C1 (MetaCons "LogAppendTime" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 Millis)) :+: C1 (MetaCons "NoTimestamp" PrefixI False) (U1 :: Type -> Type)))

data OffsetCommit

Offsets commit mode

Constructors

OffsetCommit

Forces consumer to block until the broker offsets commit is done

OffsetCommitAsync

Offsets will be committed in a non-blocking way

Instances

Eq OffsetCommit

Defined in Kafka.Consumer.Types

Methods

(==) :: OffsetCommit -> OffsetCommit -> Bool

(/=) :: OffsetCommit -> OffsetCommit -> Bool

Show OffsetCommit

Defined in Kafka.Consumer.Types

Methods

showsPrec :: Int -> OffsetCommit -> ShowS

show :: OffsetCommit -> String

showList :: [OffsetCommit] -> ShowS

Generic OffsetCommit

Defined in Kafka.Consumer.Types

Associated Types

type Rep OffsetCommit :: Type -> Type

Methods

from :: OffsetCommit -> Rep OffsetCommit x

to :: Rep OffsetCommit x -> OffsetCommit

type Rep OffsetCommit

Defined in Kafka.Consumer.Types

type Rep OffsetCommit = D1 (MetaData "OffsetCommit" "Kafka.Consumer.Types" "hw-kafka-client-4.0.2-inplace" False) (C1 (MetaCons "OffsetCommit" PrefixI False) (U1 :: Type -> Type) :+: C1 (MetaCons "OffsetCommitAsync" PrefixI False) (U1 :: Type -> Type))

data OffsetStoreSync

Indicates how offsets are to be synced to disk

Constructors

OffsetSyncDisable

Do not sync offsets (in Kafka: -1)

OffsetSyncImmediate

Sync immediately after each offset commit (in Kafka: 0)

OffsetSyncInterval Int

Sync after specified interval in millis

Instances

Eq OffsetStoreSync

Defined in Kafka.Consumer.Types

Methods

(==) :: OffsetStoreSync -> OffsetStoreSync -> Bool

(/=) :: OffsetStoreSync -> OffsetStoreSync -> Bool

Show OffsetStoreSync

Defined in Kafka.Consumer.Types

Methods

showsPrec :: Int -> OffsetStoreSync -> ShowS

show :: OffsetStoreSync -> String

showList :: [OffsetStoreSync] -> ShowS

Generic OffsetStoreSync

Defined in Kafka.Consumer.Types

Associated Types

type Rep OffsetStoreSync :: Type -> Type

Methods

from :: OffsetStoreSync -> Rep OffsetStoreSync x

to :: Rep OffsetStoreSync x -> OffsetStoreSync

type Rep OffsetStoreSync

Defined in Kafka.Consumer.Types

type Rep OffsetStoreSync = D1 (MetaData "OffsetStoreSync" "Kafka.Consumer.Types" "hw-kafka-client-4.0.2-inplace" False) (C1 (MetaCons "OffsetSyncDisable" PrefixI False) (U1 :: Type -> Type) :+: (C1 (MetaCons "OffsetSyncImmediate" PrefixI False) (U1 :: Type -> Type) :+: C1 (MetaCons "OffsetSyncInterval" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Int))))

data OffsetStoreMethod

Indicates the method of storing the offsets

Constructors

OffsetStoreBroker

Offsets are stored in Kafka broker (preferred)

OffsetStoreFile FilePath OffsetStoreSync

Offsets are stored in a file (and synced to disk according to the sync policy)

Instances

Eq OffsetStoreMethod

Defined in Kafka.Consumer.Types

Methods

(==) :: OffsetStoreMethod -> OffsetStoreMethod -> Bool

(/=) :: OffsetStoreMethod -> OffsetStoreMethod -> Bool

Show OffsetStoreMethod

Defined in Kafka.Consumer.Types

Methods

showsPrec :: Int -> OffsetStoreMethod -> ShowS

show :: OffsetStoreMethod -> String

showList :: [OffsetStoreMethod] -> ShowS

Generic OffsetStoreMethod

Defined in Kafka.Consumer.Types

Associated Types

type Rep OffsetStoreMethod :: Type -> Type

Methods

from :: OffsetStoreMethod -> Rep OffsetStoreMethod x

to :: Rep OffsetStoreMethod x -> OffsetStoreMethod

type Rep OffsetStoreMethod

Defined in Kafka.Consumer.Types

type Rep OffsetStoreMethod = D1 (MetaData "OffsetStoreMethod" "Kafka.Consumer.Types" "hw-kafka-client-4.0.2-inplace" False) (C1 (MetaCons "OffsetStoreBroker" PrefixI False) (U1 :: Type -> Type) :+: C1 (MetaCons "OffsetStoreFile" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 FilePath) :*: S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 OffsetStoreSync)))

data TopicPartition

Kafka topic partition structure

Constructors

TopicPartition

Fields

• tpTopicName :: TopicName
• tpPartition :: PartitionId
• tpOffset :: PartitionOffset

Instances

Eq TopicPartition

Defined in Kafka.Consumer.Types

Methods

(==) :: TopicPartition -> TopicPartition -> Bool

(/=) :: TopicPartition -> TopicPartition -> Bool

Show TopicPartition

Defined in Kafka.Consumer.Types

Methods

showsPrec :: Int -> TopicPartition -> ShowS

show :: TopicPartition -> String

showList :: [TopicPartition] -> ShowS

Generic TopicPartition

Defined in Kafka.Consumer.Types

Associated Types

type Rep TopicPartition :: Type -> Type

Methods

from :: TopicPartition -> Rep TopicPartition x

to :: Rep TopicPartition x -> TopicPartition

type Rep TopicPartition

Defined in Kafka.Consumer.Types

type Rep TopicPartition = D1 (MetaData "TopicPartition" "Kafka.Consumer.Types" "hw-kafka-client-4.0.2-inplace" False) (C1 (MetaCons "TopicPartition" PrefixI True) (S1 (MetaSel (Just "tpTopicName") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 TopicName) :*: (S1 (MetaSel (Just "tpPartition") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 PartitionId) :*: S1 (MetaSel (Just "tpOffset") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 PartitionOffset))))

data ConsumerRecord k v

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

Constructors

ConsumerRecord

Fields

• crTopic :: !TopicName

  Kafka topic this message was received from

• crPartition :: !PartitionId

  Kafka partition this message was received from

• crOffset :: !Offset

  Offset within the crPartition Kafka partition

• crTimestamp :: !Timestamp

  Message timestamp

• crKey :: !k

  Message key

• crValue :: !v

  Message value

Instances

Bitraversable ConsumerRecord

Defined in Kafka.Consumer.Types

Methods

bitraverse :: Applicative f => (a -> f c) -> (b -> f d) -> ConsumerRecord a b -> f (ConsumerRecord c d)

Bifoldable ConsumerRecord

Defined in Kafka.Consumer.Types

Methods

bifold :: Monoid m => ConsumerRecord m m -> m

bifoldMap :: Monoid m => (a -> m) -> (b -> m) -> ConsumerRecord a b -> m

bifoldr :: (a -> c -> c) -> (b -> c -> c) -> c -> ConsumerRecord a b -> c

bifoldl :: (c -> a -> c) -> (c -> b -> c) -> c -> ConsumerRecord a b -> c

Bifunctor ConsumerRecord

Defined in Kafka.Consumer.Types

Methods

bimap :: (a -> b) -> (c -> d) -> ConsumerRecord a c -> ConsumerRecord b d

first :: (a -> b) -> ConsumerRecord a c -> ConsumerRecord b c

second :: (b -> c) -> ConsumerRecord a b -> ConsumerRecord a c

Functor (ConsumerRecord k)

Defined in Kafka.Consumer.Types

Methods

fmap :: (a -> b) -> ConsumerRecord k a -> ConsumerRecord k b

(<$) :: a -> ConsumerRecord k b -> ConsumerRecord k a

Foldable (ConsumerRecord k)

Defined in Kafka.Consumer.Types

Methods

fold :: Monoid m => ConsumerRecord k m -> m

foldMap :: Monoid m => (a -> m) -> ConsumerRecord k a -> m

foldr :: (a -> b -> b) -> b -> ConsumerRecord k a -> b

foldr' :: (a -> b -> b) -> b -> ConsumerRecord k a -> b

foldl :: (b -> a -> b) -> b -> ConsumerRecord k a -> b

foldl' :: (b -> a -> b) -> b -> ConsumerRecord k a -> b

foldr1 :: (a -> a -> a) -> ConsumerRecord k a -> a

foldl1 :: (a -> a -> a) -> ConsumerRecord k a -> a

toList :: ConsumerRecord k a -> [a]

null :: ConsumerRecord k a -> Bool

length :: ConsumerRecord k a -> Int

elem :: Eq a => a -> ConsumerRecord k a -> Bool

maximum :: Ord a => ConsumerRecord k a -> a

minimum :: Ord a => ConsumerRecord k a -> a

sum :: Num a => ConsumerRecord k a -> a

product :: Num a => ConsumerRecord k a -> a

Traversable (ConsumerRecord k)

Defined in Kafka.Consumer.Types

Methods

traverse :: Applicative f => (a -> f b) -> ConsumerRecord k a -> f (ConsumerRecord k b)

sequenceA :: Applicative f => ConsumerRecord k (f a) -> f (ConsumerRecord k a)

mapM :: Monad m => (a -> m b) -> ConsumerRecord k a -> m (ConsumerRecord k b)

sequence :: Monad m => ConsumerRecord k (m a) -> m (ConsumerRecord k a)

(Eq k, Eq v) => Eq (ConsumerRecord k v)

Defined in Kafka.Consumer.Types

Methods

(==) :: ConsumerRecord k v -> ConsumerRecord k v -> Bool

(/=) :: ConsumerRecord k v -> ConsumerRecord k v -> Bool

(Read k, Read v) => Read (ConsumerRecord k v)

Defined in Kafka.Consumer.Types

Methods

readsPrec :: Int -> ReadS (ConsumerRecord k v)

readList :: ReadS [ConsumerRecord k v]

readPrec :: ReadPrec (ConsumerRecord k v)

readListPrec :: ReadPrec [ConsumerRecord k v]

(Show k, Show v) => Show (ConsumerRecord k v)

Defined in Kafka.Consumer.Types

Methods

showsPrec :: Int -> ConsumerRecord k v -> ShowS

show :: ConsumerRecord k v -> String

showList :: [ConsumerRecord k v] -> ShowS

Generic (ConsumerRecord k v)

Defined in Kafka.Consumer.Types

Associated Types

type Rep (ConsumerRecord k v) :: Type -> Type

Methods

from :: ConsumerRecord k v -> Rep (ConsumerRecord k v) x

to :: Rep (ConsumerRecord k v) x -> ConsumerRecord k v

type Rep (ConsumerRecord k v)

Defined in Kafka.Consumer.Types

type Rep (ConsumerRecord k v) = D1 (MetaData "ConsumerRecord" "Kafka.Consumer.Types" "hw-kafka-client-4.0.2-inplace" False) (C1 (MetaCons "ConsumerRecord" PrefixI True) ((S1 (MetaSel (Just "crTopic") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 TopicName) :*: (S1 (MetaSel (Just "crPartition") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 PartitionId) :*: S1 (MetaSel (Just "crOffset") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 Offset))) :*: (S1 (MetaSel (Just "crTimestamp") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 Timestamp) :*: (S1 (MetaSel (Just "crKey") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 k) :*: S1 (MetaSel (Just "crValue") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 v)))))

crMapKey :: (k -> k') -> ConsumerRecord k v -> ConsumerRecord k' v

Deprecated: Isn't concern of this library. Use first

crMapValue :: (v -> v') -> ConsumerRecord k v -> ConsumerRecord k v'

Deprecated: Isn't concern of this library. Use second

crMapKV :: (k -> k') -> (v -> v') -> ConsumerRecord k v -> ConsumerRecord k' v'

Deprecated: Isn't concern of this library. Use bimap

Deprecated

sequenceFirst :: (Bitraversable t, Applicative f) => t (f k) v -> f (t k v)

Deprecated: Isn't concern of this library. Use bitraverse id pure

traverseFirst :: (Bitraversable t, Applicative f) => (k -> f k') -> t k v -> f (t k' v)

Deprecated: Isn't concern of this library. Use bitraverse f pure

traverseFirstM :: (Bitraversable t, Applicative f, Monad m) => (k -> m (f k')) -> t k v -> m (f (t k' v))

Deprecated: Isn't concern of this library. Use bitraverse id pure <$> bitraverse f pure r

traverseM :: (Traversable t, Applicative f, Monad m) => (v -> m (f v')) -> t v -> m (f (t v'))

Deprecated: Isn't concern of this library. Use sequenceA <$> traverse f r

bitraverseM :: (Bitraversable t, Applicative f, Monad m) => (k -> m (f k')) -> (v -> m (f v')) -> t k v -> m (f (t k' v'))

Deprecated: Isn't concern of this library. Use bisequenceA <$> bimapM f g r