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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
