??????????????????kafka??????????????kafka??????????????????????????
kafka??kafkakafkaDebug
?????? Re: flink????kafka????????????kafka??????????????????
??kafka??Offset?? kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --zookeeper zkhost:2181 --group ${group.id} --topic ${topic_name} zkhost ??group.id??topic_name Group Topic Pid Offset logSizeLag Owner test