diff options
Diffstat (limited to 'docs')
| -rw-r--r-- | docs/streaming-kafka-0-8-integration.md | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/docs/streaming-kafka-0-8-integration.md b/docs/streaming-kafka-0-8-integration.md index d3fc9adfcf..58b17aa4ce 100644 --- a/docs/streaming-kafka-0-8-integration.md +++ b/docs/streaming-kafka-0-8-integration.md @@ -139,7 +139,7 @@ Next, we discuss how to use this approach in your streaming application. <div class="codetabs"> <div data-lang="scala" markdown="1"> // Hold a reference to the current offset ranges, so it can be used downstream - var offsetRanges = Array[OffsetRange]() + var offsetRanges = Array.empty[OffsetRange] directKafkaStream.transform { rdd => offsetRanges = rdd.asInstanceOf[HasOffsetRanges].offsetRanges |