《利用Kafka自带的命令行工具监控消费者的消费进度》由会员分享,可在线阅读,更多相关《利用Kafka自带的命令行工具监控消费者的消费进度(1页珍藏版)》请在金锄头文库上搜索。
利用kad自带的命令行工具监控消费者的消费进度Kafka官方提供了命令行工具kafka,对消费者的消费进度进行监控,在实际生产环境中,对于消费进度的监控只管重要,这直接影响消费者下游系统的消费能力和整个集群的性能。使用方法如下:在生产者端生产消息:akafka两个消费者属于同一组同时消费:kafkak/opt/module/kafka-2.11/config/consumer.propertieskafkak/opt/module/kafka-2.11/config/consumer.properties在消费者端开启对消费者组的监控:kafkaka纟吉果显加:1607403837428-e721f73e字段解释::消费者组订阅的主题:消费的分区号:该消费者组当前最新消费消息的位移值:每个分区当前最新生产的消息的位移值:生产者生产消息的位移值肖费者消费消息的位移值(此时,消费者的消费速度正好赶上生产者的生产速度)理想情况消费者