kafka-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Tom Bentley (Jira)" <j...@apache.org>
Subject [jira] [Created] (KAFKA-8862) Misleading exception message for non-existant partition
Date Tue, 03 Sep 2019 12:58:00 GMT
Tom Bentley created KAFKA-8862:
----------------------------------

             Summary: Misleading exception message for non-existant partition
                 Key: KAFKA-8862
                 URL: https://issues.apache.org/jira/browse/KAFKA-8862
             Project: Kafka
          Issue Type: Bug
          Components: producer 
    Affects Versions: 2.3.0
            Reporter: Tom Bentley
            Assignee: Tom Bentley


https://issues.apache.org/jira/browse/KAFKA-6833 changed the logic of the {{KafkaProducer.waitOnMetadata}}
so that if a partition did not exist it would wait for it to exist.
It means that if called with an incorrect partition the method will eventually throw a {{TimeoutException}},
which covers both topic and partition non-existence cases.

However, the exception message was not changed for the case where {{metadata.awaitUpdate(version,
remainingWaitMs)}} throws a {{TimeoutException}}.

This results in a confusing exception message. For example, if a producer tries to send to
a non-existent partition of an existing topic the message is 
"Topic %s not present in metadata after %d ms.", when timeout via the other code path would
come with message
"Partition %d of topic %s with partition count %d is not present in metadata after %d ms."





--
This message was sent by Atlassian Jira
(v8.3.2#803003)

Mime
View raw message