@@ -39,7 +39,7 @@ import org.apache.spark.annotation.Experimental
3939@ Experimental
4040abstract class ConsumerStrategy [K , V ] {
4141 /**
42- * Kafka <a href="http://kafka.apache.org/documentation.htmll #newconsumerconfigs">
42+ * Kafka <a href="http://kafka.apache.org/documentation.html #newconsumerconfigs">
4343 * configuration parameters</a> to be used on executors. Requires "bootstrap.servers" to be set
4444 * with Kafka broker(s) specified in host1:port1,host2:port2 form.
4545 */
@@ -59,7 +59,7 @@ abstract class ConsumerStrategy[K, V] {
5959 * Subscribe to a collection of topics.
6060 * @param topics collection of topics to subscribe
6161 * @param kafkaParams Kafka
62- * <a href="http://kafka.apache.org/documentation.htmll #newconsumerconfigs">
62+ * <a href="http://kafka.apache.org/documentation.html #newconsumerconfigs">
6363 * configuration parameters</a> to be used on driver. The same params will be used on executors,
6464 * with minor automatic modifications applied.
6565 * Requires "bootstrap.servers" to be set
@@ -93,7 +93,7 @@ private case class Subscribe[K, V](
9393 * Assign a fixed collection of TopicPartitions
9494 * @param topicPartitions collection of TopicPartitions to assign
9595 * @param kafkaParams Kafka
96- * <a href="http://kafka.apache.org/documentation.htmll #newconsumerconfigs">
96+ * <a href="http://kafka.apache.org/documentation.html #newconsumerconfigs">
9797 * configuration parameters</a> to be used on driver. The same params will be used on executors,
9898 * with minor automatic modifications applied.
9999 * Requires "bootstrap.servers" to be set
@@ -134,7 +134,7 @@ object ConsumerStrategies {
134134 * Subscribe to a collection of topics.
135135 * @param topics collection of topics to subscribe
136136 * @param kafkaParams Kafka
137- * <a href="http://kafka.apache.org/documentation.htmll #newconsumerconfigs">
137+ * <a href="http://kafka.apache.org/documentation.html #newconsumerconfigs">
138138 * configuration parameters</a> to be used on driver. The same params will be used on executors,
139139 * with minor automatic modifications applied.
140140 * Requires "bootstrap.servers" to be set
@@ -159,7 +159,7 @@ object ConsumerStrategies {
159159 * Subscribe to a collection of topics.
160160 * @param topics collection of topics to subscribe
161161 * @param kafkaParams Kafka
162- * <a href="http://kafka.apache.org/documentation.htmll #newconsumerconfigs">
162+ * <a href="http://kafka.apache.org/documentation.html #newconsumerconfigs">
163163 * configuration parameters</a> to be used on driver. The same params will be used on executors,
164164 * with minor automatic modifications applied.
165165 * Requires "bootstrap.servers" to be set
@@ -180,7 +180,7 @@ object ConsumerStrategies {
180180 * Subscribe to a collection of topics.
181181 * @param topics collection of topics to subscribe
182182 * @param kafkaParams Kafka
183- * <a href="http://kafka.apache.org/documentation.htmll #newconsumerconfigs">
183+ * <a href="http://kafka.apache.org/documentation.html #newconsumerconfigs">
184184 * configuration parameters</a> to be used on driver. The same params will be used on executors,
185185 * with minor automatic modifications applied.
186186 * Requires "bootstrap.servers" to be set
@@ -202,7 +202,7 @@ object ConsumerStrategies {
202202 * Subscribe to a collection of topics.
203203 * @param topics collection of topics to subscribe
204204 * @param kafkaParams Kafka
205- * <a href="http://kafka.apache.org/documentation.htmll #newconsumerconfigs">
205+ * <a href="http://kafka.apache.org/documentation.html #newconsumerconfigs">
206206 * configuration parameters</a> to be used on driver. The same params will be used on executors,
207207 * with minor automatic modifications applied.
208208 * Requires "bootstrap.servers" to be set
@@ -220,7 +220,7 @@ object ConsumerStrategies {
220220 * Assign a fixed collection of TopicPartitions
221221 * @param topicPartitions collection of TopicPartitions to assign
222222 * @param kafkaParams Kafka
223- * <a href="http://kafka.apache.org/documentation.htmll #newconsumerconfigs">
223+ * <a href="http://kafka.apache.org/documentation.html #newconsumerconfigs">
224224 * configuration parameters</a> to be used on driver. The same params will be used on executors,
225225 * with minor automatic modifications applied.
226226 * Requires "bootstrap.servers" to be set
@@ -245,7 +245,7 @@ object ConsumerStrategies {
245245 * Assign a fixed collection of TopicPartitions
246246 * @param topicPartitions collection of TopicPartitions to assign
247247 * @param kafkaParams Kafka
248- * <a href="http://kafka.apache.org/documentation.htmll #newconsumerconfigs">
248+ * <a href="http://kafka.apache.org/documentation.html #newconsumerconfigs">
249249 * configuration parameters</a> to be used on driver. The same params will be used on executors,
250250 * with minor automatic modifications applied.
251251 * Requires "bootstrap.servers" to be set
@@ -266,7 +266,7 @@ object ConsumerStrategies {
266266 * Assign a fixed collection of TopicPartitions
267267 * @param topicPartitions collection of TopicPartitions to assign
268268 * @param kafkaParams Kafka
269- * <a href="http://kafka.apache.org/documentation.htmll #newconsumerconfigs">
269+ * <a href="http://kafka.apache.org/documentation.html #newconsumerconfigs">
270270 * configuration parameters</a> to be used on driver. The same params will be used on executors,
271271 * with minor automatic modifications applied.
272272 * Requires "bootstrap.servers" to be set
@@ -288,7 +288,7 @@ object ConsumerStrategies {
288288 * Assign a fixed collection of TopicPartitions
289289 * @param topicPartitions collection of TopicPartitions to assign
290290 * @param kafkaParams Kafka
291- * <a href="http://kafka.apache.org/documentation.htmll #newconsumerconfigs">
291+ * <a href="http://kafka.apache.org/documentation.html #newconsumerconfigs">
292292 * configuration parameters</a> to be used on driver. The same params will be used on executors,
293293 * with minor automatic modifications applied.
294294 * Requires "bootstrap.servers" to be set
0 commit comments