Safe Haskell | None |
---|---|
Language | Haskell2010 |
Kafka.Metadata
- data KafkaMetadata = KafkaMetadata {
- kmBrokers :: [BrokerMetadata]
- kmTopics :: [TopicMetadata]
- kmOrigBroker :: !BrokerId
- data BrokerMetadata = BrokerMetadata {
- bmBrokerId :: !BrokerId
- bmBrokerHost :: !String
- bmBrokerPort :: !Int
- data TopicMetadata = TopicMetadata {}
- data PartitionMetadata = PartitionMetadata {
- pmPartitionId :: !PartitionId
- pmError :: Maybe KafkaError
- pmLeader :: !BrokerId
- pmReplicas :: [BrokerId]
- pmInSyncReplicas :: [BrokerId]
- data WatermarkOffsets = WatermarkOffsets {}
- newtype GroupMemberId = GroupMemberId String
- data GroupMemberInfo = GroupMemberInfo {}
- newtype GroupProtocolType = GroupProtocolType String
- newtype GroupProtocol = GroupProtocol String
- data GroupState
- data GroupInfo = GroupInfo {}
- allTopicsMetadata :: (MonadIO m, HasKafka k) => k -> Timeout -> m (Either KafkaError KafkaMetadata)
- topicMetadata :: (MonadIO m, HasKafka k) => k -> Timeout -> TopicName -> m (Either KafkaError KafkaMetadata)
- watermarkOffsets :: (MonadIO m, HasKafka k) => k -> Timeout -> TopicName -> m [Either KafkaError WatermarkOffsets]
- watermarkOffsets' :: (MonadIO m, HasKafka k) => k -> Timeout -> TopicMetadata -> m [Either KafkaError WatermarkOffsets]
- partitionWatermarkOffsets :: (MonadIO m, HasKafka k) => k -> Timeout -> TopicName -> PartitionId -> m (Either KafkaError WatermarkOffsets)
- offsetsForTime :: (MonadIO m, HasKafka k) => k -> Timeout -> Millis -> [(TopicName, PartitionId)] -> m (Either KafkaError [TopicPartition])
- offsetsForTime' :: (MonadIO m, HasKafka k) => k -> Timeout -> Millis -> TopicMetadata -> m (Either KafkaError [TopicPartition])
- topicOffsetsForTime :: (MonadIO m, HasKafka k) => k -> Timeout -> Millis -> TopicName -> m (Either KafkaError [TopicPartition])
- allConsumerGroupsInfo :: (MonadIO m, HasKafka k) => k -> Timeout -> m (Either KafkaError [GroupInfo])
- consumerGroupInfo :: (MonadIO m, HasKafka k) => k -> Timeout -> ConsumerGroupId -> m (Either KafkaError [GroupInfo])
Documentation
data KafkaMetadata Source #
Constructors
KafkaMetadata | |
Fields
|
Instances
data BrokerMetadata Source #
Constructors
BrokerMetadata | |
Fields
|
Instances
data TopicMetadata Source #
Constructors
TopicMetadata | |
Fields
|
Instances
data PartitionMetadata Source #
Constructors
PartitionMetadata | |
Fields
|
Instances
data WatermarkOffsets Source #
Constructors
WatermarkOffsets | |
Fields
|
Instances
data GroupMemberInfo Source #
Constructors
GroupMemberInfo | |
Fields
|
Instances
newtype GroupProtocolType Source #
Constructors
GroupProtocolType String |
data GroupState Source #
Constructors
GroupPreparingRebalance | Group is preparing to rebalance |
GroupEmpty | Group has no more members, but lingers until all offsets have expired |
GroupAwaitingSync | Group is awaiting state assignment from the leader |
GroupStable | Group is stable |
GroupDead | Group has no more members and its metadata is being removed |
Instances
Constructors
GroupInfo | |
Fields
|
allTopicsMetadata :: (MonadIO m, HasKafka k) => k -> Timeout -> m (Either KafkaError KafkaMetadata) Source #
Returns metadata for all topics in the cluster
topicMetadata :: (MonadIO m, HasKafka k) => k -> Timeout -> TopicName -> m (Either KafkaError KafkaMetadata) Source #
Returns metadata only for specified topic
watermarkOffsets :: (MonadIO m, HasKafka k) => k -> Timeout -> TopicName -> m [Either KafkaError WatermarkOffsets] Source #
Query broker for low (oldestbeginning) and high (newestend) offsets for a given topic.
watermarkOffsets' :: (MonadIO m, HasKafka k) => k -> Timeout -> TopicMetadata -> m [Either KafkaError WatermarkOffsets] Source #
Query broker for low (oldestbeginning) and high (newestend) offsets for a given topic.
partitionWatermarkOffsets :: (MonadIO m, HasKafka k) => k -> Timeout -> TopicName -> PartitionId -> m (Either KafkaError WatermarkOffsets) Source #
Query broker for low (oldestbeginning) and high (newestend) offsets for a specific partition
offsetsForTime :: (MonadIO m, HasKafka k) => k -> Timeout -> Millis -> [(TopicName, PartitionId)] -> m (Either KafkaError [TopicPartition]) Source #
Look up the offsets for the given partitions by timestamp.
The returned offset for each partition is the earliest offset whose timestamp is greater than or equal to the given timestamp in the corresponding partition.
offsetsForTime' :: (MonadIO m, HasKafka k) => k -> Timeout -> Millis -> TopicMetadata -> m (Either KafkaError [TopicPartition]) Source #
Look up the offsets for the given metadata by timestamp.
The returned offset for each partition is the earliest offset whose timestamp is greater than or equal to the given timestamp in the corresponding partition.
topicOffsetsForTime :: (MonadIO m, HasKafka k) => k -> Timeout -> Millis -> TopicName -> m (Either KafkaError [TopicPartition]) Source #
Look up the offsets for the given topic by timestamp.
The returned offset for each partition is the earliest offset whose timestamp is greater than or equal to the given timestamp in the corresponding partition.
allConsumerGroupsInfo :: (MonadIO m, HasKafka k) => k -> Timeout -> m (Either KafkaError [GroupInfo]) Source #
List and describe all consumer groups in cluster.
consumerGroupInfo :: (MonadIO m, HasKafka k) => k -> Timeout -> ConsumerGroupId -> m (Either KafkaError [GroupInfo]) Source #
Describe a given consumer group.