flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Tzu-Li (Gordon) Tai (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-7224) Incorrect Javadoc description in all Kafka consumer versions
Date Wed, 19 Jul 2017 06:16:00 GMT
Tzu-Li (Gordon) Tai created FLINK-7224:
------------------------------------------

             Summary: Incorrect Javadoc description in all Kafka consumer versions
                 Key: FLINK-7224
                 URL: https://issues.apache.org/jira/browse/FLINK-7224
             Project: Flink
          Issue Type: Improvement
          Components: Kafka Connector
    Affects Versions: 1.3.1, 1.4.0
            Reporter: Tzu-Li (Gordon) Tai
            Assignee: Tzu-Li (Gordon) Tai


Currently, all Kafka consumer version still have this in the Javadoc:

{code}
The implementation currently accesses partition metadata when the consumer
is constructed. That means that the client that submits the program needs to be able to
reach the Kafka brokers or ZooKeeper.
{code}

This is no longer true since Flink 1.3. partition metadata happens only in {{open()}}.



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)

Mime
View raw message