kafka-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Jason Aliyetti (JIRA)" <j...@apache.org>
Subject [jira] [Created] (KAFKA-4472) offsetRetentionMs miscalculated in GroupCoordinator
Date Thu, 01 Dec 2016 02:57:58 GMT
Jason Aliyetti created KAFKA-4472:

             Summary: offsetRetentionMs miscalculated in GroupCoordinator
                 Key: KAFKA-4472
                 URL: https://issues.apache.org/jira/browse/KAFKA-4472
             Project: Kafka
          Issue Type: Bug
    Affects Versions:,
            Reporter: Jason Aliyetti

The configuration "offsets.retention.minutes" is documented as being an integer.  When large
values are set (i.e. Integer.MAX_VALUE), an overflow error occurs when converting from minutes
to milliseconds.  For instance, setting the config value as 2147483647 results in a offsetsRetentionMs
of -60000.  This means that all committed offsets are past their expiration when they are
created and will be nullified on the next expiration check, which is unexpected given the
type of the configuration.

The fix would be to change
"offsetsRetentionMs = config.offsetsRetentionMinutes * 60 * 1000L"
"offsetsRetentionMs = config.offsetsRetentionMinutes * 60L * 1000L"
in GroupCoordinator.apply().

This message was sent by Atlassian JIRA

View raw message