Safe Haskell | None |
---|---|
Language | Haskell2010 |
Network.Kafka.Protocol
Documentation
Constructors
Request (CorrelationId, ClientId, RequestMessage) |
Instances
Eq Request Source # | |
Show Request Source # | |
Generic Request Source # | |
Serializable Request Source # | |
type Rep Request Source # | |
Defined in Network.Kafka.Protocol type Rep Request = D1 (MetaData "Request" "Network.Kafka.Protocol" "milena-0.5.3.0-56TArgubqLBEBU4ve7tukD" True) (C1 (MetaCons "Request" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 (CorrelationId, ClientId, RequestMessage)))) |
data KafkaError Source #
Constructors
NoError |
|
Unknown |
|
OffsetOutOfRange |
|
InvalidMessage |
|
UnknownTopicOrPartition |
|
InvalidMessageSize |
|
LeaderNotAvailable |
|
NotLeaderForPartition |
|
RequestTimedOut |
|
BrokerNotAvailable |
|
ReplicaNotAvailable |
|
MessageSizeTooLarge |
|
StaleControllerEpochCode |
|
OffsetMetadataTooLargeCode |
|
OffsetsLoadInProgressCode |
|
ConsumerCoordinatorNotAvailableCode |
|
NotCoordinatorForConsumerCode |
|
TopicAlreadyExists |
|
UnsupportedCompressionType |
|
Instances
Constructors
Metadata KafkaString |
Instances
Eq Metadata Source # | |
Show Metadata Source # | |
IsString Metadata Source # | |
Defined in Network.Kafka.Protocol Methods fromString :: String -> Metadata # | |
Generic Metadata Source # | |
Deserializable Metadata Source # | |
Defined in Network.Kafka.Protocol Methods | |
Serializable Metadata Source # | |
type Rep Metadata Source # | |
Defined in Network.Kafka.Protocol type Rep Metadata = D1 (MetaData "Metadata" "Network.Kafka.Protocol" "milena-0.5.3.0-56TArgubqLBEBU4ve7tukD" True) (C1 (MetaCons "Metadata" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 KafkaString))) |
newtype ConsumerGroup Source #
Constructors
ConsumerGroup KafkaString |
Instances
newtype OffsetFetchRequest Source #
Constructors
OffsetFetchReq (ConsumerGroup, [(TopicName, [Partition])]) |
Instances
newtype OffsetCommitRequest Source #
Constructors
OffsetCommitReq (ConsumerGroup, [(TopicName, [(Partition, Offset, Time, Metadata)])]) |
Instances
newtype CreateTopicsRequest Source #
Constructors
CreateTopicsReq ([(TopicName, Partition, ReplicationFactor, [(Partition, Replicas)], [(KafkaString, Metadata)])], Timeout) |
Instances
newtype GroupCoordinatorRequest Source #
Constructors
GroupCoordinatorReq ConsumerGroup |
Instances
newtype ReplicationFactor Source #
Constructors
ReplicationFactor Int16 |
Instances
data ResponseMessage Source #
Constructors
Instances
Constructors
Value | |
Fields |
Instances
Eq Value Source # | |
Show Value Source # | |
Generic Value Source # | |
Deserializable Value Source # | |
Defined in Network.Kafka.Protocol Methods deserialize :: Get Value Source # | |
Serializable Value Source # | |
type Rep Value Source # | |
Defined in Network.Kafka.Protocol type Rep Value = D1 (MetaData "Value" "Network.Kafka.Protocol" "milena-0.5.3.0-56TArgubqLBEBU4ve7tukD" True) (C1 (MetaCons "Value" PrefixI True) (S1 (MetaSel (Just "_valueBytes") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 (Maybe KafkaBytes)))) |
Constructors
Key | |
Fields |
Instances
Eq Key Source # | |
Show Key Source # | |
Generic Key Source # | |
Deserializable Key Source # | |
Defined in Network.Kafka.Protocol Methods deserialize :: Get Key Source # | |
Serializable Key Source # | |
type Rep Key Source # | |
Defined in Network.Kafka.Protocol type Rep Key = D1 (MetaData "Key" "Network.Kafka.Protocol" "milena-0.5.3.0-56TArgubqLBEBU4ve7tukD" True) (C1 (MetaCons "Key" PrefixI True) (S1 (MetaSel (Just "_keyBytes") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 (Maybe KafkaBytes)))) |
data Attributes Source #
Constructors
Attributes | |
Fields |
Instances
Eq Attributes Source # | |
Defined in Network.Kafka.Protocol | |
Show Attributes Source # | |
Defined in Network.Kafka.Protocol Methods showsPrec :: Int -> Attributes -> ShowS # show :: Attributes -> String # showList :: [Attributes] -> ShowS # | |
Generic Attributes Source # | |
Defined in Network.Kafka.Protocol Associated Types type Rep Attributes :: Type -> Type # | |
Deserializable Attributes Source # | |
Defined in Network.Kafka.Protocol Methods | |
Serializable Attributes Source # | |
Defined in Network.Kafka.Protocol Methods serialize :: Attributes -> Put Source # | |
type Rep Attributes Source # | |
Defined in Network.Kafka.Protocol type Rep Attributes = D1 (MetaData "Attributes" "Network.Kafka.Protocol" "milena-0.5.3.0-56TArgubqLBEBU4ve7tukD" False) (C1 (MetaCons "Attributes" PrefixI True) (S1 (MetaSel (Just "_compressionCodec") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 CompressionCodec))) |
Instances
Instances
Enum Crc Source # | |
Eq Crc Source # | |
Integral Crc Source # | |
Num Crc Source # | |
Ord Crc Source # | |
Real Crc Source # | |
Defined in Network.Kafka.Protocol Methods toRational :: Crc -> Rational # | |
Show Crc Source # | |
Generic Crc Source # | |
Deserializable Crc Source # | |
Defined in Network.Kafka.Protocol Methods deserialize :: Get Crc Source # | |
Serializable Crc Source # | |
type Rep Crc Source # | |
Defined in Network.Kafka.Protocol |
data CompressionCodec Source #
Constructors
NoCompression | |
Gzip |
Instances
Eq CompressionCodec Source # | |
Defined in Network.Kafka.Protocol Methods (==) :: CompressionCodec -> CompressionCodec -> Bool # (/=) :: CompressionCodec -> CompressionCodec -> Bool # | |
Show CompressionCodec Source # | |
Defined in Network.Kafka.Protocol Methods showsPrec :: Int -> CompressionCodec -> ShowS # show :: CompressionCodec -> String # showList :: [CompressionCodec] -> ShowS # | |
Generic CompressionCodec Source # | |
Defined in Network.Kafka.Protocol Associated Types type Rep CompressionCodec :: Type -> Type # Methods from :: CompressionCodec -> Rep CompressionCodec x # to :: Rep CompressionCodec x -> CompressionCodec # | |
type Rep CompressionCodec Source # | |
Constructors
Message | |
Fields
|
Instances
Enum Offset Source # | |
Defined in Network.Kafka.Protocol | |
Eq Offset Source # | |
Integral Offset Source # | |
Defined in Network.Kafka.Protocol | |
Num Offset Source # | |
Ord Offset Source # | |
Real Offset Source # | |
Defined in Network.Kafka.Protocol Methods toRational :: Offset -> Rational # | |
Show Offset Source # | |
Generic Offset Source # | |
Deserializable Offset Source # | |
Defined in Network.Kafka.Protocol Methods deserialize :: Get Offset Source # | |
Serializable Offset Source # | |
type Rep Offset Source # | |
Defined in Network.Kafka.Protocol |
data MessageSetMember Source #
Constructors
MessageSetMember | |
Fields
|
Instances
data MessageSet Source #
Constructors
MessageSet | |
Fields |
Instances
Eq MessageSet Source # | |
Defined in Network.Kafka.Protocol | |
Show MessageSet Source # | |
Defined in Network.Kafka.Protocol Methods showsPrec :: Int -> MessageSet -> ShowS # show :: MessageSet -> String # showList :: [MessageSet] -> ShowS # | |
Generic MessageSet Source # | |
Defined in Network.Kafka.Protocol Associated Types type Rep MessageSet :: Type -> Type # | |
Deserializable MessageSet Source # | |
Defined in Network.Kafka.Protocol Methods | |
Serializable MessageSet Source # | |
Defined in Network.Kafka.Protocol Methods serialize :: MessageSet -> Put Source # | |
type Rep MessageSet Source # | |
Defined in Network.Kafka.Protocol type Rep MessageSet = D1 (MetaData "MessageSet" "Network.Kafka.Protocol" "milena-0.5.3.0-56TArgubqLBEBU4ve7tukD" False) (C1 (MetaCons "MessageSet" PrefixI True) (S1 (MetaSel (Just "_codec") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 CompressionCodec) :*: S1 (MetaSel (Just "_messageSetMembers") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 [MessageSetMember]))) |
Instances
Instances
Enum Timeout Source # | |
Eq Timeout Source # | |
Integral Timeout Source # | |
Defined in Network.Kafka.Protocol | |
Num Timeout Source # | |
Ord Timeout Source # | |
Defined in Network.Kafka.Protocol | |
Real Timeout Source # | |
Defined in Network.Kafka.Protocol Methods toRational :: Timeout -> Rational # | |
Show Timeout Source # | |
Generic Timeout Source # | |
Deserializable Timeout Source # | |
Defined in Network.Kafka.Protocol Methods deserialize :: Get Timeout Source # | |
Serializable Timeout Source # | |
type Rep Timeout Source # | |
Defined in Network.Kafka.Protocol |
newtype RequiredAcks Source #
Constructors
RequiredAcks Int16 |
Instances
newtype ProduceRequest Source #
Constructors
ProduceReq (RequiredAcks, Timeout, [(TopicName, [(Partition, MessageSet)])]) |
Instances
Instances
Enum MaxBytes Source # | |
Defined in Network.Kafka.Protocol | |
Eq MaxBytes Source # | |
Integral MaxBytes Source # | |
Defined in Network.Kafka.Protocol | |
Num MaxBytes Source # | |
Ord MaxBytes Source # | |
Defined in Network.Kafka.Protocol | |
Real MaxBytes Source # | |
Defined in Network.Kafka.Protocol Methods toRational :: MaxBytes -> Rational # | |
Show MaxBytes Source # | |
Generic MaxBytes Source # | |
Deserializable MaxBytes Source # | |
Defined in Network.Kafka.Protocol Methods | |
Serializable MaxBytes Source # | |
type Rep MaxBytes Source # | |
Defined in Network.Kafka.Protocol |
Instances
Enum MinBytes Source # | |
Defined in Network.Kafka.Protocol | |
Eq MinBytes Source # | |
Integral MinBytes Source # | |
Defined in Network.Kafka.Protocol | |
Num MinBytes Source # | |
Ord MinBytes Source # | |
Defined in Network.Kafka.Protocol | |
Real MinBytes Source # | |
Defined in Network.Kafka.Protocol Methods toRational :: MinBytes -> Rational # | |
Show MinBytes Source # | |
Generic MinBytes Source # | |
Deserializable MinBytes Source # | |
Defined in Network.Kafka.Protocol Methods | |
Serializable MinBytes Source # | |
type Rep MinBytes Source # | |
Defined in Network.Kafka.Protocol |
newtype MaxWaitTime Source #
Constructors
MaxWaitTime Int32 |
Instances
Instances
newtype FetchRequest Source #
Constructors
FetchReq (ReplicaId, MaxWaitTime, MinBytes, [(TopicName, [(Partition, Offset, MaxBytes)])]) |
Instances
Eq FetchRequest Source # | |
Defined in Network.Kafka.Protocol | |
Show FetchRequest Source # | |
Defined in Network.Kafka.Protocol Methods showsPrec :: Int -> FetchRequest -> ShowS # show :: FetchRequest -> String # showList :: [FetchRequest] -> ShowS # | |
Generic FetchRequest Source # | |
Defined in Network.Kafka.Protocol Associated Types type Rep FetchRequest :: Type -> Type # | |
Deserializable FetchRequest Source # | |
Defined in Network.Kafka.Protocol Methods | |
Serializable FetchRequest Source # | |
Defined in Network.Kafka.Protocol Methods serialize :: FetchRequest -> Put Source # | |
type Rep FetchRequest Source # | |
Defined in Network.Kafka.Protocol type Rep FetchRequest = D1 (MetaData "FetchRequest" "Network.Kafka.Protocol" "milena-0.5.3.0-56TArgubqLBEBU4ve7tukD" True) (C1 (MetaCons "FetchReq" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 (ReplicaId, MaxWaitTime, MinBytes, [(TopicName, [(Partition, Offset, MaxBytes)])])))) |
newtype MaxNumberOfOffsets Source #
Constructors
MaxNumberOfOffsets Int32 |
Instances
Instances
Bounded Time Source # | |
Enum Time Source # | |
Eq Time Source # | |
Integral Time Source # | |
Num Time Source # | |
Ord Time Source # | |
Real Time Source # | |
Defined in Network.Kafka.Protocol Methods toRational :: Time -> Rational # | |
Show Time Source # | |
Generic Time Source # | |
Serializable Time Source # | |
type Rep Time Source # | |
Defined in Network.Kafka.Protocol |
newtype OffsetRequest Source #
Instances
Eq OffsetRequest Source # | |
Defined in Network.Kafka.Protocol Methods (==) :: OffsetRequest -> OffsetRequest -> Bool # (/=) :: OffsetRequest -> OffsetRequest -> Bool # | |
Show OffsetRequest Source # | |
Defined in Network.Kafka.Protocol Methods showsPrec :: Int -> OffsetRequest -> ShowS # show :: OffsetRequest -> String # showList :: [OffsetRequest] -> ShowS # | |
Generic OffsetRequest Source # | |
Defined in Network.Kafka.Protocol Associated Types type Rep OffsetRequest :: Type -> Type # | |
Serializable OffsetRequest Source # | |
Defined in Network.Kafka.Protocol Methods serialize :: OffsetRequest -> Put Source # | |
type Rep OffsetRequest Source # | |
Defined in Network.Kafka.Protocol type Rep OffsetRequest = D1 (MetaData "OffsetRequest" "Network.Kafka.Protocol" "milena-0.5.3.0-56TArgubqLBEBU4ve7tukD" True) (C1 (MetaCons "OffsetReq" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 (ReplicaId, [(TopicName, [(Partition, Time, MaxNumberOfOffsets)])])))) |
newtype OffsetFetchResponse Source #
Constructors
OffsetFetchResp [(TopicName, [(Partition, Offset, Metadata, KafkaError)])] |
Instances
newtype OffsetCommitResponse Source #
Constructors
OffsetCommitResp [(TopicName, [(Partition, KafkaError)])] |
Instances
newtype PartitionMetadata Source #
Constructors
PartitionMetadata | |
Fields |
Instances
newtype TopicMetadata Source #
Constructors
TopicMetadata | |
Fields |
Instances
Eq TopicMetadata Source # | |
Defined in Network.Kafka.Protocol Methods (==) :: TopicMetadata -> TopicMetadata -> Bool # (/=) :: TopicMetadata -> TopicMetadata -> Bool # | |
Show TopicMetadata Source # | |
Defined in Network.Kafka.Protocol Methods showsPrec :: Int -> TopicMetadata -> ShowS # show :: TopicMetadata -> String # showList :: [TopicMetadata] -> ShowS # | |
Generic TopicMetadata Source # | |
Defined in Network.Kafka.Protocol Associated Types type Rep TopicMetadata :: Type -> Type # | |
Deserializable TopicMetadata Source # | |
Defined in Network.Kafka.Protocol Methods | |
type Rep TopicMetadata Source # | |
Defined in Network.Kafka.Protocol type Rep TopicMetadata = D1 (MetaData "TopicMetadata" "Network.Kafka.Protocol" "milena-0.5.3.0-56TArgubqLBEBU4ve7tukD" True) (C1 (MetaCons "TopicMetadata" PrefixI True) (S1 (MetaSel (Just "_topicMetadataFields") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 (KafkaError, TopicName, [PartitionMetadata])))) |
Instances
Enum Port Source # | |
Eq Port Source # | |
Integral Port Source # | |
Num Port Source # | |
Ord Port Source # | |
Real Port Source # | |
Defined in Network.Kafka.Protocol Methods toRational :: Port -> Rational # | |
Show Port Source # | |
Generic Port Source # | |
Deserializable Port Source # | |
Defined in Network.Kafka.Protocol Methods deserialize :: Get Port Source # | |
type Rep Port Source # | |
Defined in Network.Kafka.Protocol |
Constructors
Host | |
Fields |
Instances
Eq Host Source # | |
Ord Host Source # | |
Show Host Source # | |
IsString Host Source # | |
Defined in Network.Kafka.Protocol Methods fromString :: String -> Host # | |
Generic Host Source # | |
Deserializable Host Source # | |
Defined in Network.Kafka.Protocol Methods deserialize :: Get Host Source # | |
type Rep Host Source # | |
Defined in Network.Kafka.Protocol type Rep Host = D1 (MetaData "Host" "Network.Kafka.Protocol" "milena-0.5.3.0-56TArgubqLBEBU4ve7tukD" True) (C1 (MetaCons "Host" PrefixI True) (S1 (MetaSel (Just "_hostKString") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 KafkaString))) |
Instances
Enum NodeId Source # | |
Defined in Network.Kafka.Protocol | |
Eq NodeId Source # | |
Integral NodeId Source # | |
Defined in Network.Kafka.Protocol | |
Num NodeId Source # | |
Ord NodeId Source # | |
Real NodeId Source # | |
Defined in Network.Kafka.Protocol Methods toRational :: NodeId -> Rational # | |
Show NodeId Source # | |
Generic NodeId Source # | |
Deserializable NodeId Source # | |
Defined in Network.Kafka.Protocol Methods deserialize :: Get NodeId Source # | |
type Rep NodeId Source # | |
Defined in Network.Kafka.Protocol |
Constructors
Broker | |
Fields
|
newtype MetadataResponse Source #
Constructors
MetadataResp | |
Fields
|
Instances
newtype CreateTopicsResponse Source #
Constructors
TopicsResp | |
Fields
|
Instances
newtype FetchResponse Source #
Constructors
FetchResp | |
Fields
|
Instances
newtype PartitionOffsets Source #
Constructors
PartitionOffsets | |
Fields
|
Instances
newtype OffsetResponse Source #
Constructors
OffsetResp | |
Fields
|
Instances
newtype ProduceResponse Source #
Constructors
ProduceResp | |
Fields
|
Instances
newtype KafkaString Source #
Constructors
KString | |
Fields |
Instances
newtype KafkaBytes Source #
Constructors
KBytes | |
Fields |
Instances
Eq KafkaBytes Source # | |
Defined in Network.Kafka.Protocol | |
Show KafkaBytes Source # | |
Defined in Network.Kafka.Protocol Methods showsPrec :: Int -> KafkaBytes -> ShowS # show :: KafkaBytes -> String # showList :: [KafkaBytes] -> ShowS # | |
IsString KafkaBytes Source # | |
Defined in Network.Kafka.Protocol Methods fromString :: String -> KafkaBytes # | |
Generic KafkaBytes Source # | |
Defined in Network.Kafka.Protocol Associated Types type Rep KafkaBytes :: Type -> Type # | |
Deserializable KafkaBytes Source # | |
Defined in Network.Kafka.Protocol Methods | |
Serializable KafkaBytes Source # | |
Defined in Network.Kafka.Protocol Methods serialize :: KafkaBytes -> Put Source # | |
type Rep KafkaBytes Source # | |
Defined in Network.Kafka.Protocol type Rep KafkaBytes = D1 (MetaData "KafkaBytes" "Network.Kafka.Protocol" "milena-0.5.3.0-56TArgubqLBEBU4ve7tukD" True) (C1 (MetaCons "KBytes" PrefixI True) (S1 (MetaSel (Just "_kafkaByteString") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 ByteString))) |
Constructors
TName | |
Fields |
Instances
Eq TopicName Source # | |
Ord TopicName Source # | |
Show TopicName Source # | |
IsString TopicName Source # | |
Defined in Network.Kafka.Protocol Methods fromString :: String -> TopicName # | |
Generic TopicName Source # | |
Deserializable TopicName Source # | |
Defined in Network.Kafka.Protocol Methods | |
Serializable TopicName Source # | |
type Rep TopicName Source # | |
Defined in Network.Kafka.Protocol type Rep TopicName = D1 (MetaData "TopicName" "Network.Kafka.Protocol" "milena-0.5.3.0-56TArgubqLBEBU4ve7tukD" True) (C1 (MetaCons "TName" PrefixI True) (S1 (MetaSel (Just "_tName") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 KafkaString))) |
newtype MetadataRequest Source #
Constructors
MetadataReq [TopicName] |
Instances
data RequestMessage Source #
Constructors
Instances
Constructors
ClientId KafkaString |
Instances
Eq ClientId Source # | |
Show ClientId Source # | |
IsString ClientId Source # | |
Defined in Network.Kafka.Protocol Methods fromString :: String -> ClientId # | |
Generic ClientId Source # | |
Deserializable ClientId Source # | |
Defined in Network.Kafka.Protocol Methods | |
Serializable ClientId Source # | |
type Rep ClientId Source # | |
Defined in Network.Kafka.Protocol type Rep ClientId = D1 (MetaData "ClientId" "Network.Kafka.Protocol" "milena-0.5.3.0-56TArgubqLBEBU4ve7tukD" True) (C1 (MetaCons "ClientId" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 KafkaString))) |
newtype CorrelationId Source #
Constructors
CorrelationId Int32 |
Instances
newtype ApiVersion Source #
Constructors
ApiVersion Int16 |
Instances
Instances
Enum ApiKey Source # | |
Defined in Network.Kafka.Protocol | |
Eq ApiKey Source # | |
Integral ApiKey Source # | |
Defined in Network.Kafka.Protocol | |
Num ApiKey Source # | |
Ord ApiKey Source # | |
Real ApiKey Source # | |
Defined in Network.Kafka.Protocol Methods toRational :: ApiKey -> Rational # | |
Show ApiKey Source # | |
Generic ApiKey Source # | |
Deserializable ApiKey Source # | |
Defined in Network.Kafka.Protocol Methods deserialize :: Get ApiKey Source # | |
Serializable ApiKey Source # | |
type Rep ApiKey Source # | |
Defined in Network.Kafka.Protocol |
newtype GroupCoordinatorResponse Source #
Constructors
GroupCoordinatorResp (KafkaError, Broker) |
Instances
class Deserializable a where Source #
Methods
deserialize :: Get a Source #
Instances
class Serializable a where Source #
Instances
Constructors
MetadataRR :: MonadIO m => MetadataRequest -> ReqResp (m MetadataResponse) | |
ProduceRR :: MonadIO m => ProduceRequest -> ReqResp (m ProduceResponse) | |
FetchRR :: MonadIO m => FetchRequest -> ReqResp (m FetchResponse) | |
OffsetRR :: MonadIO m => OffsetRequest -> ReqResp (m OffsetResponse) | |
TopicsRR :: MonadIO m => CreateTopicsRequest -> ReqResp (m CreateTopicsResponse) |
doRequest' :: (Deserializable a, MonadIO m) => CorrelationId -> Handle -> Request -> m (Either String a) Source #
doRequest :: MonadIO m => ClientId -> CorrelationId -> Handle -> ReqResp (m a) -> m (Either String a) Source #
errorKafka :: KafkaError -> Int16 Source #
requestBytes :: Request -> ByteString Source #
apiKey :: RequestMessage -> ApiKey Source #
produceResponseFields :: Iso' ProduceResponse [(TopicName, [(Partition, KafkaError, Offset)])] Source #
fetchResponseFields :: Iso' FetchResponse [(TopicName, [(Partition, KafkaError, Offset, MessageSet)])] Source #
partitionMetadataFields :: Iso' PartitionMetadata (KafkaError, Partition, Leader, Replicas, Isr) Source #
messageFields :: Iso' Message (Crc, MagicByte, Attributes, Key, Value) Source #
valueBytes :: Iso' Value (Maybe KafkaBytes) Source #
fetchResponseByTopic :: TopicName -> Fold FetchResponse (Partition, KafkaError, Offset, MessageSet) Source #
messageSetByPartition :: Partition -> Fold (Partition, KafkaError, Offset, MessageSet) MessageSetMember Source #
findPartitionMetadata :: Applicative f => TopicName -> LensLike' f TopicMetadata [PartitionMetadata] Source #
portId :: IndexPreservingGetter Port PortID Source #