Welcome to OGeek Q&A Community for programmer and developer-Open, Learning and Share
Welcome To Ask or Share your Answers For Others

Categories

0 votes
532 views
in Technique[技术] by (71.8m points)

spring boot - how to get the last committed offset for a consumer in Kafka?

I have an Spring Boot Microservice app that reads from a Kafka Topic . the app read from the topic and stopped midway before it consumes all of the data from the topic.The app has been stopped for 2 months and now when I start the app back its showing a load of 0 which is wrong as it hasn't read all of the data? Is there a way to get the last committed offset for a consumer ?

question from:https://stackoverflow.com/questions/65888989/how-to-get-the-last-committed-offset-for-a-consumer-in-kafka

与恶龙缠斗过久,自身亦成为恶龙;凝视深渊过久,深渊将回以凝视…
Welcome To Ask or Share your Answers For Others

1 Reply

0 votes
by (71.8m points)

You can use kafka-consumer-groups --bootstrap-server <brokers> --group <id> --describe to find the committed offsets

If the current and latest offets match, or the lag is zero, then there are no messages to read


与恶龙缠斗过久,自身亦成为恶龙;凝视深渊过久,深渊将回以凝视…
OGeek|极客中国-欢迎来到极客的世界,一个免费开放的程序员编程交流平台!开放,进步,分享!让技术改变生活,让极客改变未来! Welcome to OGeek Q&A Community for programmer and developer-Open, Learning and Share
Click Here to Ask a Question

...