jsancio commented on code in PR #11023: URL: https://github.com/apache/kafka/pull/11023#discussion_r996333678
########## clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java: ########## @@ -778,9 +778,13 @@ public Future<RecordMetadata> send(ProducerRecord<K, V> record) { /** * Asynchronously send a record to a topic and invoke the provided callback when the send has been acknowledged. * <p> - * The send is asynchronous and this method will return immediately once the record has been stored in the buffer of + * The send is asynchronous and this method will return immediately (except for getting the topic metadata if it + * doesn't have the necessary information about the topic) once the record has been stored in the buffer of * records waiting to be sent. This allows sending many records in parallel without blocking to wait for the * response after each one. + * Note, that getting metadata part of a method is blocking. This happens for the first record being sent to + * the cluster by this client for the given topic. In this case it will block (for up to maxBlockTimeMs) if Review Comment: Let's use `max.block.ms`. `maxBlockTimeMs` is an internal field that the user doesn't know about. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org