Minor changes.

Author: tdas

external/kafka/src/main/scala/org/apache/spark/streaming/kafka/OffsetRange.scala

@@ -50,7 +50,7 @@ final class OffsetRange private(
   }
 
   override def toString(): String = {
-    s"OffsetRange(topic='$topic', partition=$partition, range: [$fromOffset -> $untilOffset]"
+    s"OffsetRange(topic: '$topic', partition: $partition, range: [$fromOffset -> $untilOffset]"
   }
 
   /** this is to avoid ClassNotFoundException during checkpoint restore */

external/kafka/src/test/scala/org/apache/spark/streaming/kafka/DirectKafkaStreamSuite.scala

@@ -34,7 +34,7 @@ import org.apache.spark.streaming.dstream.{DStream, InputDStream}
 import org.apache.spark.util.Utils
 
 class DirectKafkaStreamSuite extends KafkaStreamSuiteBase
-with BeforeAndAfter with BeforeAndAfterAll with Eventually {
+  with BeforeAndAfter with BeforeAndAfterAll with Eventually {
   val sparkConf = new SparkConf()
     .setMaster("local[4]")
     .setAppName(this.getClass.getSimpleName)