From 2f4fb7b8fd7f442cd84bb7ba758a6e82d9b89912 Mon Sep 17 00:00:00 2001 From: jeff.maxwell Date: Tue, 23 Jun 2015 11:05:01 -0500 Subject: [PATCH] KAFKA-2294 fixed bad javadoc tag on close() that fails java 8 --- .../src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java b/clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java index 5a37580..5671a3f 100644 --- a/clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java +++ b/clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java @@ -522,7 +522,8 @@ public class KafkaProducer implements Producer { * If close() is called from {@link Callback}, a warning message will be logged and close(0, TimeUnit.MILLISECONDS) * will be called instead. We do this because the sender thread would otherwise try to join itself and * block forever. - *

+ *

+ * * @throws InterruptException If the thread is interrupted while blocked */ @Override -- 1.9.5.msysgit.0