Github user hmcl commented on a diff in the pull request:
https://github.com/apache/storm/pull/2465#discussion_r157831079
--- Diff:
external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/KafkaSpoutConfig.java
---
@@ -115,26 +115,30 @@ public KafkaSpoutConfig(Builder<K, V> builder) {
}
/**
- * The offset used by the Kafka spout in the first poll to Kafka
broker. The choice of this parameter will affect the number of consumer
- * records returned in the first poll. By default this parameter is
set to UNCOMMITTED_EARLIEST. <br/><br/>
+ * Defines the offset used by the {@link KafkaSpout} in the first poll
to Kafka broker. The choice of this parameter will affect
+ * the number of consumer records returned in the first poll. By
default this parameter is set to UNCOMMITTED_EARLIEST. <br/><br/>
--- End diff --
OK.
---
