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: 0.10.0.1, 0.10.1.0
            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"
to
"offsetsRetentionMs = config.offsetsRetentionMinutes * 60L * 1000L"
in GroupCoordinator.apply().



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Reply via email to