Source code:
/** <code>metadata.fetch.timeout.ms</code> */
public static final String METADATA_FETCH_TIMEOUT_CONFIG = "
metadata.fetch.timeout.ms";
private static final String METADATA_FETCH_TIMEOUT_DOC = "The first
time data is sent to a topic we must fetch metadata about that topic to
know which servers host the " + "topic's partitions. This configuration
controls the maximum amount of time we will block waiting for the metadata "
+ "fetch to
succeed before throwing an exception back to the client.";
/** <code>metadata.max.age.ms</code> */
public static final String METADATA_MAX_AGE_CONFIG = "
metadata.max.age.ms";
private static final String METADATA_MAX_AGE_DOC = "The period of time
in milliseconds after which we force a refresh of metadata even if we
haven't seen any " + " partition leadership changes to proactively discover
any new brokers or partitions.";
Even though the *max.age.ms <http://max.age.ms>* is set to 30 minutes, it
still tries to update almost every 10 seconds when it fails. Am I doing
something wrong with producer initializing and closing?
On Wed, Mar 11, 2015 at 2:20 AM, Achanta Vamsi Subhash <
[email protected]> wrote:
> Hi,
>
> I am intermittently getting the following exception when producing the
> messages using 0.8.2 new producer:
>
> java.util.concurrent.ExecutionException:
> org.apache.kafka.common.errors.TimeoutException: Failed to update metadata
> after 60000 ms.
>
> Network connectivity is fine and the brokers are all up and fine. What
> could be the reason?
>
> --
> Regards
> Vamsi Subhash
>
--
Regards
Vamsi Subhash
