| 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.