spark-instrumented-optimizer/external/kafka/src
jerluc 9188ad8ddb [SPARK-7621] [STREAMING] Report Kafka errors to StreamingListeners
PR per [SPARK-7621](https://issues.apache.org/jira/browse/SPARK-7621), which makes both `KafkaReceiver` and `ReliableKafkaReceiver` report its errors to the `ReceiverTracker`, which in turn will add the events to the bus to fire off any registered `StreamingListener`s.

Author: jerluc <jeremyalucas@gmail.com>

Closes #6204 from jerluc/master and squashes the following commits:

82439a5 [jerluc] [SPARK-7621] [STREAMING] Report Kafka errors to StreamingListeners

(cherry picked from commit 0a7a94eab5)
Signed-off-by: Tathagata Das <tathagata.das1565@gmail.com>
2015-05-18 18:13:43 -07:00
..
main/scala/org/apache/spark/streaming/kafka [SPARK-7621] [STREAMING] Report Kafka errors to StreamingListeners 2015-05-18 18:13:43 -07:00
test [SPARK-7113] [STREAMING] Support input information reporting for Direct Kafka stream 2015-05-05 02:06:58 -07:00