Merge pull request #27 from lightbend/misc

Added copyright info, updated README

README.md

@@ -13,7 +13,7 @@ The design of the library was inspired by the work started by Alexis Seigneurin
 `kafka-streams-scala` is published and cross-built for Scala `2.11`, and `2.12`, so you can just add the following to your build:
 
 ```scala
-val kafka_streams_scala_version = "0.0.1"
+val kafka_streams_scala_version = "0.1.0"
 
 libraryDependencies ++= Seq("com.lightbend" %%
   "kafka-streams-scala" % kafka_streams_scala_version)

src/main/scala/com/lightbend/kafka/scala/streams/FunctionConversions.scala

@@ -1,3 +1,7 @@
+/**
+ * Copyright (C) 2018 Lightbend Inc. <https://www.lightbend.com>
+ */
+
 package com.lightbend.kafka.scala.streams
 
 import org.apache.kafka.streams.KeyValue

src/main/scala/com/lightbend/kafka/scala/streams/ImplicitConversions.scala

@@ -1,3 +1,7 @@
+/**
+ * Copyright (C) 2018 Lightbend Inc. <https://www.lightbend.com>
+ */
+
 package com.lightbend.kafka.scala.streams
 
 import org.apache.kafka.streams.kstream._

src/main/scala/com/lightbend/kafka/scala/streams/KGroupedStreamS.scala

@@ -1,3 +1,7 @@
+/**
+ * Copyright (C) 2018 Lightbend Inc. <https://www.lightbend.com>
+ */
+
 package com.lightbend.kafka.scala.streams
 
 import org.apache.kafka.streams.kstream._

src/main/scala/com/lightbend/kafka/scala/streams/KGroupedTableS.scala

@@ -1,3 +1,7 @@
+/**
+ * Copyright (C) 2018 Lightbend Inc. <https://www.lightbend.com>
+ */
+
 package com.lightbend.kafka.scala.streams
 
 import ImplicitConversions._

src/main/scala/com/lightbend/kafka/scala/streams/KStreamS.scala

@@ -1,3 +1,7 @@
+/**
+ * Copyright (C) 2018 Lightbend Inc. <https://www.lightbend.com>
+ */
+
 package com.lightbend.kafka.scala.streams
 
 import org.apache.kafka.streams.KeyValue

src/main/scala/com/lightbend/kafka/scala/streams/KTableS.scala

@@ -1,3 +1,7 @@
+/**
+ * Copyright (C) 2018 Lightbend Inc. <https://www.lightbend.com>
+ */
+
 package com.lightbend.kafka.scala.streams
 
 import org.apache.kafka.streams.kstream._

src/main/scala/com/lightbend/kafka/scala/streams/SessionWindowedKStreamS.scala

@@ -1,3 +1,7 @@
+/**
+ * Copyright (C) 2018 Lightbend Inc. <https://www.lightbend.com>
+ */
+
 package com.lightbend.kafka.scala.streams
 
 import org.apache.kafka.streams.kstream._

src/main/scala/com/lightbend/kafka/scala/streams/StreamsBuilderS.scala

@@ -1,3 +1,7 @@
+/**
+ * Copyright (C) 2018 Lightbend Inc. <https://www.lightbend.com>
+ */
+
 package com.lightbend.kafka.scala.streams
 
 import java.util.regex.Pattern

src/main/scala/com/lightbend/kafka/scala/streams/TimeWindowedKStreamS.scala

@@ -1,3 +1,7 @@
+/**
+ * Copyright (C) 2018 Lightbend Inc. <https://www.lightbend.com>
+ */
+
 package com.lightbend.kafka.scala.streams
 
 import org.apache.kafka.streams.kstream._

src/test/scala/com/lightbend/kafka/scala/server/KafkaLocalServer.scala

@@ -1,3 +1,7 @@
+/**
+ * Copyright (C) 2018 Lightbend Inc. <https://www.lightbend.com>
+ */
+
 package com.lightbend.kafka.scala.server
 
 // Loosely based on Lagom implementation at

src/test/scala/com/lightbend/kafka/scala/server/MessageListener.scala

@@ -1,3 +1,7 @@
+/**
+ * Copyright (C) 2018 Lightbend Inc. <https://www.lightbend.com>
+ */
+
 package com.lightbend.kafka.scala.server
 
 import org.apache.kafka.clients.consumer.{ ConsumerConfig, KafkaConsumer }

src/test/scala/com/lightbend/kafka/scala/server/MessageSender.scala

@@ -1,3 +1,7 @@
+/**
+ * Copyright (C) 2018 Lightbend Inc. <https://www.lightbend.com>
+ */
+
 package com.lightbend.kafka.scala.server
 
 import org.apache.kafka.clients.producer.{ KafkaProducer, ProducerConfig, ProducerRecord, RecordMetadata }

src/test/scala/com/lightbend/kafka/scala/server/RecordProcessorTrait.scala

@@ -1,3 +1,7 @@
+/**
+ * Copyright (C) 2018 Lightbend Inc. <https://www.lightbend.com>
+ */
+
 package com.lightbend.kafka.scala.server
 
 import org.apache.kafka.clients.consumer.ConsumerRecord

src/test/scala/com/lightbend/kafka/scala/server/Utils.scala

@@ -1,3 +1,7 @@
+/**
+ * Copyright (C) 2018 Lightbend Inc. <https://www.lightbend.com>
+ */
+
 package com.lightbend.kafka.scala.server
 
 

src/test/scala/com/lightbend/kafka/scala/streams/KafkaStreamsTest.scala

@@ -1,3 +1,7 @@
+/**
+ * Copyright (C) 2018 Lightbend Inc. <https://www.lightbend.com>
+ */
+
 package com.lightbend.kafka.scala.streams
 
 import minitest.TestSuite

src/test/scala/com/lightbend/kafka/scala/streams/ProbabilisticCountingScalaIntegrationTest.scala

@@ -1,3 +1,8 @@
+/**
+ * Copyright (C) 2018 Lightbend Inc. <https://www.lightbend.com>
+ * Adapted from Confluent Inc. whose copyright is reproduced below.
+ */
+
 /*
  * Copyright Confluent Inc.
  *

src/test/scala/com/lightbend/kafka/scala/streams/StreamToTableJoinScalaIntegrationTest.scala

@@ -1,3 +1,8 @@
+/**
+ * Copyright (C) 2018 Lightbend Inc. <https://www.lightbend.com>
+ * Adapted from Confluent Inc. whose copyright is reproduced below.
+ */
+
 /*
  * Copyright Confluent Inc.
  *