zoukankan      html  css  js  c++  java
  • kafka偏移量 select_kafka_offset

    #/bin/bash
    #定义变量
    #假设kafka-consumer-groups.sh路径为 /home/ss/kafka_2.11-2.3.0/bin/
    kafka_path=/home/ss/kafka_2.11-2.3.0/bin/
    kafka_ip=10.201.1.60
    kafka_port=9092
    kafka_group1=inside_group-inside_vam_attach_img
    kafka_group2=inside_group-common_log_output
    kafka_group3=inside_group_inside_attach_person_result
    #kafka_group4=dragon_42_inside_ams_attach_person_result_group
    kafka_group5=inside_group-mysql_inside_metal_detector_result
    kafka_group6=inside_group-inside_monitor_result_push
    kafka_group7=inside_group-mysql_inside_metal_detector_status_result
    kafka_group8=inside_group-inside_vam_gate_events
    #kafka_group9=dragon_42_inside_ams_patrol_query_logs_group
    #kafka_group10=dragon_42_inside_ams_gate_events_group
    kafka_group11=inside_group-inside_vam_patrol_query_logs
    kafka_group12=inside_group-inside_vcn_pids_alarm
    kafka_group13=inside_group-inside_cnl_vf_groups
    kafka_group14=inside_group-inside_ests_device_events
    kafka_group15=inside_group-inside_yitu_fp_alarm
    kafka_group16=inside_group-inside_vam_psa_log
    kafka_group17=inside_group-inside_ests_upstreaming_trip_event
    kafka_group18=inside_group-inside_vam_aab_state
    kafka_group19=inside_group-inside_ests_trip_gps
    kafka_group20=inside_group-inside_yitu_ai_behavior
    kafka_group21=inside_group-inside_ests_trip_data
    kafka_group22=inside_group-inside_vam_banned_vehicle
    kafka_group23=inside_group-inside_vam_banned_person
    kafka_group24=inside_group-inside_yitu_pepole_count_result
    #进入kafka_home/bin目录
    cd ${kafka_path}
    ./kafka-consumer-groups.sh --bootstrap-server ${kafka_ip}:${kafka_port} --describe --group ${kafka_group1} --command-config ../config/consumer.properties
    ./kafka-consumer-groups.sh --bootstrap-server ${kafka_ip}:${kafka_port} --describe --group ${kafka_group2} --command-config ../config/consumer.properties
    ./kafka-consumer-groups.sh --bootstrap-server ${kafka_ip}:${kafka_port} --describe --group ${kafka_group3} --command-config ../config/consumer.properties
    #./kafka-consumer-groups.sh --bootstrap-server ${kafka_ip}:${kafka_port} --describe --group ${kafka_group4} --command-config ../config/consumer.properties
    ./kafka-consumer-groups.sh --bootstrap-server ${kafka_ip}:${kafka_port} --describe --group ${kafka_group5} --command-config ../config/consumer.properties
    ./kafka-consumer-groups.sh --bootstrap-server ${kafka_ip}:${kafka_port} --describe --group ${kafka_group6} --command-config ../config/consumer.properties
    ./kafka-consumer-groups.sh --bootstrap-server ${kafka_ip}:${kafka_port} --describe --group ${kafka_group7} --command-config ../config/consumer.properties
    ./kafka-consumer-groups.sh --bootstrap-server ${kafka_ip}:${kafka_port} --describe --group ${kafka_group8} --command-config ../config/consumer.properties
    #./kafka-consumer-groups.sh --bootstrap-server ${kafka_ip}:${kafka_port} --describe --group ${kafka_group9} --command-config ../config/consumer.properties
    #./kafka-consumer-groups.sh --bootstrap-server ${kafka_ip}:${kafka_port} --describe --group ${kafka_group10} --command-config ../config/consumer.properties
    ./kafka-consumer-groups.sh --bootstrap-server ${kafka_ip}:${kafka_port} --describe --group ${kafka_group11} --command-config ../config/consumer.properties
    ./kafka-consumer-groups.sh --bootstrap-server ${kafka_ip}:${kafka_port} --describe --group ${kafka_group12} --command-config ../config/consumer.properties
    ./kafka-consumer-groups.sh --bootstrap-server ${kafka_ip}:${kafka_port} --describe --group ${kafka_group13} --command-config ../config/consumer.properties
    ./kafka-consumer-groups.sh --bootstrap-server ${kafka_ip}:${kafka_port} --describe --group ${kafka_group14} --command-config ../config/consumer.properties
    ./kafka-consumer-groups.sh --bootstrap-server ${kafka_ip}:${kafka_port} --describe --group ${kafka_group15} --command-config ../config/consumer.properties
    ./kafka-consumer-groups.sh --bootstrap-server ${kafka_ip}:${kafka_port} --describe --group ${kafka_group16} --command-config ../config/consumer.properties
    ./kafka-consumer-groups.sh --bootstrap-server ${kafka_ip}:${kafka_port} --describe --group ${kafka_group17} --command-config ../config/consumer.properties
    ./kafka-consumer-groups.sh --bootstrap-server ${kafka_ip}:${kafka_port} --describe --group ${kafka_group18} --command-config ../config/consumer.properties
    ./kafka-consumer-groups.sh --bootstrap-server ${kafka_ip}:${kafka_port} --describe --group ${kafka_group19} --command-config ../config/consumer.properties
    ./kafka-consumer-groups.sh --bootstrap-server ${kafka_ip}:${kafka_port} --describe --group ${kafka_group20} --command-config ../config/consumer.properties
    ./kafka-consumer-groups.sh --bootstrap-server ${kafka_ip}:${kafka_port} --describe --group ${kafka_group21} --command-config ../config/consumer.properties
    ./kafka-consumer-groups.sh --bootstrap-server ${kafka_ip}:${kafka_port} --describe --group ${kafka_group22} --command-config ../config/consumer.properties
    ./kafka-consumer-groups.sh --bootstrap-server ${kafka_ip}:${kafka_port} --describe --group ${kafka_group23} --command-config ../config/consumer.properties
    ./kafka-consumer-groups.sh --bootstrap-server ${kafka_ip}:${kafka_port} --describe --group ${kafka_group24} --command-config ../config/consumer.properties

  • 相关阅读:
    自定义Listview
    android ListView嵌套GridView显示不全问题
    Android-Universal-Image-Loader 图片异步加载类库的使用(超详细配置)
    android service被系统回收的解决方法
    android Activity基类通用方法
    用 FragmentManager 替换时使用 GoogleMaps 崩溃 app
    Gulp 从0开始
    面试题 之 全排列
    面试题之 query转为obj
    this .运算符 和 [] 运算符
  • 原文地址:https://www.cnblogs.com/seamy/p/15762204.html
Copyright © 2011-2022 走看看