推荐阅读更多精彩内容

• flink如何管理kafka消费位点（原：how flink manages kafka co...

  本文为翻译flink作者之一Fabian Hueske的文章 原文：https://www.ververica.c...

  Watchi阅读 2,636评论 0赞 1
• kafka消费者偏移量手动管理-同步提交

  kafka消费者偏移量手动管理-同步提交 首先，我们将参数enable.auto.commit参数的值设为fals...

  ShiPF阅读 948评论 0赞 1
• 深入了解Kafka【四】消费者的Offset管理

  1、Offset Topic Consumer通过提交Offset来记录当前消费的最后位置，以便于消费者发生崩溃或...

  ClawHub的技术分享阅读 637评论 0赞 1
• kafka 消费组管理

  1、查看消费组 ./kafka-consumer-groups.sh --bootstrap-server loc...

  jokeryyds阅读 241评论 0赞 0
• Flink如何管理Kafka 消费位点(译文)

  Checkpointing 是 Flink 故障恢复的内部机制。一个 checkpoint 就是 Flink应用程...

  小胡子哥灬阅读 2,270评论 0赞 7