From 9fa64101ccdbfd05998ef12fad68bbebbde898d3 Mon Sep 17 00:00:00 2001 From: Lee Dongjin Date: Mon, 16 Sep 2019 23:45:57 +0900 Subject: [PATCH] Fix javadoc at org.apache.kafka.clients.producer.KafkaProducer.InterceptorCallback#onCompletion --- examples/src/main/java/kafka/examples/Producer.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/examples/src/main/java/kafka/examples/Producer.java b/examples/src/main/java/kafka/examples/Producer.java index b6998c58ac756..80417027e202b 100644 --- a/examples/src/main/java/kafka/examples/Producer.java +++ b/examples/src/main/java/kafka/examples/Producer.java @@ -84,8 +84,8 @@ public DemoCallBack(long startTime, int key, String message) { * be called when the record sent to the server has been acknowledged. When exception is not null in the callback, * metadata will contain the special -1 value for all fields except for topicPartition, which will be valid. * - * @param metadata The metadata for the record that was sent (i.e. the partition and offset). Null if an error - * occurred. + * @param metadata The metadata for the record that was sent (i.e. the partition and offset). An empty metadata + * with -1 value for all fields except for topicPartition will be returned if an error occurred. * @param exception The exception thrown during processing of this record. Null if no error occurred. */ public void onCompletion(RecordMetadata metadata, Exception exception) {