How does offsets.retention.minutes work

[tao xiao <xi...@gmail.com>]

Hi team,

I know that Kafka deletes offset for a consumer group after a period of
time (configured by offsets.retention.minutes) if the consumer group is
inactive for this amount of time. I want to understand the definition of
"inactive". I came across this post[1] and it suggests that no offset
committed for this amount of time is considered inactive. Does it mean that
even I have a consumer group that connects to Kafka all the time but no
offset is committed for that amount of time, the offset will still be
deleted?




[1]
http://stackoverflow.com/questions/39131465/how-does-an-offset-expire-for-an-apache-kafka-consumer-group

Re: How does offsets.retention.minutes work

[James Cheng <wu...@gmail.com>]

Yes, that is correct. I filed a JIRA about that issue here:

https://issues.apache.org/jira/browse/KAFKA-4682

-James

> On Mar 15, 2017, at 8:51 PM, tao xiao <xi...@gmail.com> wrote:
> 
> Hi team,
> 
> I know that Kafka deletes offset for a consumer group after a period of
> time (configured by offsets.retention.minutes) if the consumer group is
> inactive for this amount of time. I want to understand the definition of
> "inactive". I came across this post[1] and it suggests that no offset
> committed for this amount of time is considered inactive. Does it mean that
> even I have a consumer group that connects to Kafka all the time but no
> offset is committed for that amount of time, the offset will still be
> deleted?
> 
> 
> 
> 
> [1]
> http://stackoverflow.com/questions/39131465/how-does-an-offset-expire-for-an-apache-kafka-consumer-group