@@ -290,8 +290,9 @@ object KafkaUtils {
290
290
291
291
/**
292
292
* :: Experimental ::
293
- * Create an input stream that pulls messages from a Kafka Broker. This stream can guarantee
294
- * that each message from Kafka is included in transformations exactly once (see points below).
293
+ * Create an input stream that directly pulls messages from a Kafka Broker
294
+ * without using any receiver. This stream can guarantee that each message
295
+ * from Kafka is included in transformations exactly once (see points below).
295
296
*
296
297
* Points to note:
297
298
* - No receivers: This stream does not use any receiver. It directly queries Kafka
@@ -336,8 +337,9 @@ object KafkaUtils {
336
337
337
338
/**
338
339
* :: Experimental ::
339
- * Create an input stream that pulls messages from a Kafka Broker. This stream can guarantee
340
- * that each message from Kafka is included in transformations exactly once (see points below).
340
+ * Create an input stream that directly pulls messages from a Kafka Broker
341
+ * without using any receiver. This stream can guarantee that each message
342
+ * from Kafka is included in transformations exactly once (see points below).
341
343
*
342
344
* Points to note:
343
345
* - No receivers: This stream does not use any receiver. It directly queries Kafka
@@ -399,8 +401,9 @@ object KafkaUtils {
399
401
400
402
/**
401
403
* :: Experimental ::
402
- * Create an input stream that pulls messages from a Kafka Broker. This stream can guarantee
403
- * that each message from Kafka is included in transformations exactly once (see points below).
404
+ * Create an input stream that directly pulls messages from a Kafka Broker
405
+ * without using any receiver. This stream can guarantee that each message
406
+ * from Kafka is included in transformations exactly once (see points below).
404
407
*
405
408
* Points to note:
406
409
* - No receivers: This stream does not use any receiver. It directly queries Kafka
@@ -459,8 +462,9 @@ object KafkaUtils {
459
462
460
463
/**
461
464
* :: Experimental ::
462
- * Create an input stream that pulls messages from a Kafka Broker. This stream can guarantee
463
- * that each message from Kafka is included in transformations exactly once (see points below).
465
+ * Create an input stream that directly pulls messages from a Kafka Broker
466
+ * without using any receiver. This stream can guarantee that each message
467
+ * from Kafka is included in transformations exactly once (see points below).
464
468
*
465
469
* Points to note:
466
470
* - No receivers: This stream does not use any receiver. It directly queries Kafka
0 commit comments