diff options
Diffstat (limited to 'docs/streaming-kafka-integration.md')
| -rw-r--r-- | docs/streaming-kafka-integration.md | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/docs/streaming-kafka-integration.md b/docs/streaming-kafka-integration.md index 775d508d48..7571e22575 100644 --- a/docs/streaming-kafka-integration.md +++ b/docs/streaming-kafka-integration.md @@ -152,7 +152,7 @@ Next, we discuss how to use this approach in your streaming application. </div> <div data-lang="java" markdown="1"> // Hold a reference to the current offset ranges, so it can be used downstream - final AtomicReference<OffsetRange[]> offsetRanges = new AtomicReference(); + final AtomicReference<OffsetRange[]> offsetRanges = new AtomicReference<>(); directKafkaStream.transformToPair( new Function<JavaPairRDD<String, String>, JavaPairRDD<String, String>>() { |