[ 
https://issues.apache.org/jira/browse/KAFKA-10753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17236189#comment-17236189
 ] 

lqjacklee commented on KAFKA-10753:
-----------------------------------


{code:java}
public void reset(long timeoutMs) {
        if (timeoutMs < 0)
            throw new IllegalArgumentException("Invalid negative timeout " + 
timeoutMs);

        this.timeoutMs = timeoutMs;
        this.startMs = this.currentTimeMs;

        if (currentTimeMs > Long.MAX_VALUE - timeoutMs)
            this.deadlineMs = Long.MAX_VALUE;
        else
            this.deadlineMs = currentTimeMs + timeoutMs;
    }
{code}




> check if ConsumerConfig.AUTO_COMMIT_INTERVAL_MS_CONFIG > 0 
> -----------------------------------------------------------
>
>                 Key: KAFKA-10753
>                 URL: https://issues.apache.org/jira/browse/KAFKA-10753
>             Project: Kafka
>          Issue Type: Improvement
>          Components: consumer
>            Reporter: shiqihao
>            Assignee: lqjacklee
>            Priority: Minor
>
> I accidentally set ConsumerConfig.AUTO_COMMIT_INTERVAL_MS_CONFIG = 0, CPU 
> running at 100%.
> Could we add a check if ConsumerConfig.AUTO_COMMIT_INTERVAL_MS_CONFIG > 0 
> while start consumer?



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to