搜索
搜索

偏移量存储为Kafka时如何检查消费者偏移量？

Abhiram 发表于 Dev
15
阿比拉姆

从0.8.1.1版本中，卡夫卡提供了计提卡夫卡偏移的存储，而不是动物园管理员（见本）。我无法弄清楚如何检查所消耗补偿的细节，因为目前的工具只能提供给仅供饲养员消费者偏移计数检查。（我指的是这个）

如果有任何工具可用来检查消费者抵销，请告知我。

柔术

我正在使用带有存储在kafka中的偏移量的kafka 0.8.2。该工具对我有用：

./kafka-run-class.sh kafka.tools.ConsumerOffsetChecker 
        --topic your-topic 
        --group your-consumer-group
        --zookeeper localhost:2181

您将获得所需的所有信息：主题大小，消费者滞后，所有者。

本文收集自互联网，转载请注明来源。

如有侵权，请联系[email protected] 删除。

编辑于
0

我来说两句

0条评论
登录后参与评论

相关文章

来自分类Dev

为风暴消费者检查 Kafka 主题的偏移量

来自分类Dev

Kafka：如何修复偏移量损坏的问题，以及如何手动重置消费者的偏移量以再次读取？

来自分类Dev

在 Kafka 中，消费者在哪个 __consumer_offsets 分区上提交偏移量？

来自分类Dev

如何在Spring Kafka中禁用提交偏移量以在本地存储偏移量？

来自分类Dev

Kafka：消费者api：无法使用kafka-consumer-api从偏移量手动读取和确认

来自分类Dev

卡夫卡消费者在处理后但在提交偏移量之前崩溃？

来自分类Dev

Apache Kafka偏移量是如何生成的？

来自分类Dev

卡夫卡消费者的偏移量和滞后时间（通过新的消费者API创建）设置为未知

来自分类Dev

DatetimeIndex的偏移量为

来自分类Dev

解释Kafka中的复制偏移量检查点和恢复点偏移量

来自分类Dev

Kafka Consumer偏移量提交检查以避免提交较小的偏移量

来自分类Dev

在Kafka中，如何在两个偏移量之间重播kafka使用者？

来自分类Dev

Kafka Connect偏移量。获取/设置？

来自分类Dev

Kafka-偏移量和logSize

来自分类Dev

Kafka分区偏移量分布不均

来自分类Dev

autoconf：检查成员的偏移量

来自分类Dev

autoconf：检查成员的偏移量

来自分类Dev

如何获取kafka主题分区的最后/结束偏移量？

来自分类Dev

如何获取kafka主题分区的最新偏移量？

来自分类Dev

Flink（Kafka源代码）如何管理偏移量？

来自分类Dev

如何使用 Spring for Kafka 寻找时间戳的偏移量

来自分类Dev

单张为标记添加偏移量

来自分类Dev

Kafka-如何使用高级使用者在每条消息后提交偏移量？

来自分类Dev

在reloadRowsAtIndexPaths时保持偏移量

来自分类Dev

在Storm中，如何将偏移量迁移到Kafka中存储？

来自分类Dev

在Storm中，如何将偏移量迁移到Kafka中存储？

来自分类Dev

未定义偏移量：检查函数中是否设置了is时为1

来自分类Dev

如何将“浮士德”中的使用者设置为特定的偏移量

来自分类Dev

当偏移量可变时，如何获取“ next”事件？

Related 相关文章

  1. 1

    为风暴消费者检查 Kafka 主题的偏移量

  2. 2

    Kafka：如何修复偏移量损坏的问题，以及如何手动重置消费者的偏移量以再次读取？

  3. 3

    在 Kafka 中，消费者在哪个 __consumer_offsets 分区上提交偏移量？

  4. 4

    如何在Spring Kafka中禁用提交偏移量以在本地存储偏移量？

  5. 5

    Kafka：消费者api：无法使用kafka-consumer-api从偏移量手动读取和确认

  6. 6

    卡夫卡消费者在处理后但在提交偏移量之前崩溃？

  7. 7

    Apache Kafka偏移量是如何生成的？

  8. 8

    卡夫卡消费者的偏移量和滞后时间（通过新的消费者API创建）设置为未知

  9. 9

    DatetimeIndex的偏移量为

  10. 10

    解释Kafka中的复制偏移量检查点和恢复点偏移量

  11. 11

    Kafka Consumer偏移量提交检查以避免提交较小的偏移量

  12. 12

    在Kafka中，如何在两个偏移量之间重播kafka使用者？

  13. 13

    Kafka Connect偏移量。获取/设置？

  14. 14

    Kafka-偏移量和logSize

  15. 15

    Kafka分区偏移量分布不均

  16. 16

    autoconf：检查成员的偏移量

  17. 17

    autoconf：检查成员的偏移量

  18. 18

    如何获取kafka主题分区的最后/结束偏移量？

  19. 19

    如何获取kafka主题分区的最新偏移量？

  20. 20

    Flink（Kafka源代码）如何管理偏移量？

  21. 21

    如何使用 Spring for Kafka 寻找时间戳的偏移量

  22. 22

    单张为标记添加偏移量

  23. 23

    Kafka-如何使用高级使用者在每条消息后提交偏移量？

  24. 24

    在reloadRowsAtIndexPaths时保持偏移量

  25. 25

    在Storm中，如何将偏移量迁移到Kafka中存储？

  26. 26

    在Storm中，如何将偏移量迁移到Kafka中存储？

  27. 27

    未定义偏移量：检查函数中是否设置了is时为1

  28. 28

    如何将“浮士德”中的使用者设置为特定的偏移量

  29. 29

    当偏移量可变时，如何获取“ next”事件？

热门标签

归档