From 03a54bf2d593e07ab602f6a9425d0231a273ba5a Mon Sep 17 00:00:00 2001
From: Naveen Madhire <naveen.madhire@capitalone.com>
Date: Mon, 16 Nov 2015 13:32:17 -0600
Subject: [PATCH] Changes after review

---
 .../java/org/apache/nifi/processors/kafka/GetKafka.java     | 6 ++----
 1 file changed, 2 insertions(+), 4 deletions(-)

diff --git a/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/main/java/org/apache/nifi/processors/kafka/GetKafka.java b/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/main/java/org/apache/nifi/processors/kafka/GetKafka.java
index e644064f5e..4be6194723 100644
--- a/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/main/java/org/apache/nifi/processors/kafka/GetKafka.java
+++ b/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/main/java/org/apache/nifi/processors/kafka/GetKafka.java
@@ -69,9 +69,7 @@ import kafka.message.MessageAndMetadata;
         @WritesAttribute(attribute = "kafka.key", description = "The key of the Kafka message, if it exists and batch size is 1. If"
                 + " the message does not have a key, or if the batch size is greater than 1, this attribute will not be added"),
         @WritesAttribute(attribute = "kafka.partition", description = "The partition of the Kafka Topic from which the message was received. This attribute is added only if the batch size is 1"),
-        @WritesAttribute(attribute = "kafka.offset", description = "The offset of the message within the Kafka partition. This attribute is added only if the batch size is 1"),
-        @WritesAttribute(attribute = "auto.offset.reset", description = "If this is set to largest, the consumer may lose some messages when the number of partitions, " +
-                "for the topics it subscribes to, changes on the broker. To prevent data loss during partition addition, set auto.offset.reset to smallest")})
+        @WritesAttribute(attribute = "kafka.offset", description = "The offset of the message within the Kafka partition. This attribute is added only if the batch size is 1")})
 public class GetKafka extends AbstractProcessor {
 
     public static final String SMALLEST = "smallest";
@@ -155,7 +153,7 @@ public class GetKafka extends AbstractProcessor {
 
     public static final PropertyDescriptor AUTO_OFFSET_RESET = new PropertyDescriptor.Builder()
             .name("Auto Offset Reset")
-            .description("Auto Offset Reset indicator")
+            .description("Automatically reset the offset to the smallest or largest offset available on the broker")
             .required(true)
             .allowableValues(SMALLEST, LARGEST)
             .defaultValue(LARGEST)