??????????????????kafka??????????????kafka??????????????????????????
kafka??kafkakafkaDebug ??AbstractFetcher.java ?? emitRecordsWithTimestamps ??for?? ?? AbstractFetcher emitRecordsWithTimestamps ?? protected void emitRecordsWithTimestamps( Queue
?????? 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
logSize Lag
Owner
test dy_event
0
8115733 10658588
2542855 none
test dy_event
1
8114221 10658585
2544364 none
test dy_event
2
8115173 10658587
2543414 none
test dy_event
3
8115127 10658585
2543458 none
test dy_event
4
8115160 10658587
2543427 none
pid Offset??
-- --
??: "Benchao Li"https://ci.apache.org/projects/flink/flink-docs-master/dev/connectors/kafka.html#kafka-consumers-offset-committing-behaviour-configuration
wqpapa https://ci.apache.org/projects/flink/flink-docs-master/dev/connectors/kafka.html#kafka-consumers-start-position-configuration
> >
> >wqpapa
flink消费kafka kafka的current-offset不动
求助各位大牛，同样的代码逻辑写在单独的main函数中就可以成功的消费kafka ，写在一个spring boot的程序中，接受外部请求，然后执行相同的逻辑就不能消费kafka。有人遇到过吗？大牛们能给一些查问题的建议，或者在哪里打个断点，能看到为什么消费不到kafka的消息呢？
