You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "Ryan P (JIRA)" <ji...@apache.org> on 2016/04/08 21:20:25 UTC
[jira] [Resolved] (KAFKA-3533) Kafka Consumer Config validation
should be AND not OR
[ https://issues.apache.org/jira/browse/KAFKA-3533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Ryan P resolved KAFKA-3533.
---------------------------
Resolution: Invalid
Misinterpreted the intended purpose of this check.
> Kafka Consumer Config validation should be AND not OR
> -----------------------------------------------------
>
> Key: KAFKA-3533
> URL: https://issues.apache.org/jira/browse/KAFKA-3533
> Project: Kafka
> Issue Type: Bug
> Reporter: Ryan P
> Labels: Newbie
>
> There seems to be a bit of an inconsistency between between the configuration validation imposed in the KafkaConsumer class and the error message presented:
> https://github.com/apache/kafka/blob/trunk/clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java#L556-L557
> Based on the error message the request timeout should be greater than the session timeout and the max fetch wait timeout. The validation logic however checks to ensure that either operand is true, not both.
> In the event that your request timeout is greater than the session timeout the operation will be short-circuited allowing for a potential misconfiguration of the consumer.
> Based on what I can tell the error message is correct and the validation check is incorrect.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)