lianetm commented on code in PR #20533:
URL: https://github.com/apache/kafka/pull/20533#discussion_r2718140752
##########
clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java:
##########
@@ -1027,15 +1027,15 @@ public Future<RecordMetadata> send(ProducerRecord<K, V>
record) {
* expensive callbacks it is recommended to use your own {@link
java.util.concurrent.Executor} in the callback body
* to parallelize processing.
*
- * @param record The record to send
+ * @param record The record to send
* @param callback A user-supplied callback to execute when the record has
been acknowledged by the server (null
- * indicates no callback)
- *
- * @throws IllegalStateException if a transactional.id has been configured
and no transaction has been started, or
- * when send is invoked after producer has
been closed.
- * @throws InterruptException If the thread is interrupted while blocked
+ * indicates no callback)
+ * @throws IllegalStateException if a transactional.id has been
configured and no transaction has been started, or
+ * when send is invoked after producer has
been closed.
+ * @throws TimeoutException if the topic or the partition specified
in the record cannot be found in metadata within {@code max.block.ms}
Review Comment:
This is not accurate here, there is a timeout but not thrown on send, it's
on the future returned instead. Fixed here
https://github.com/apache/kafka/pull/21347
--
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]
