Skip to content
This repository was archived by the owner on May 25, 2023. It is now read-only.

Commit d2cf871

Browse files
committed
Added copyright info, updated README
1 parent fe66910 commit d2cf871

18 files changed

+71
-1
lines changed

README.md

+1-1
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,7 @@ The design of the library was inspired by the work started by Alexis Seigneurin
1313
`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:
1414

1515
```scala
16-
val kafka_streams_scala_version = "0.0.1"
16+
val kafka_streams_scala_version = "0.1.0"
1717

1818
libraryDependencies ++= Seq("com.lightbend" %%
1919
"kafka-streams-scala" % kafka_streams_scala_version)

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

+4
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,7 @@
1+
/**
2+
* Copyright (C) 2018 Lightbend Inc. <https://www.lightbend.com>
3+
*/
4+
15
package com.lightbend.kafka.scala.streams
26

37
import org.apache.kafka.streams.KeyValue

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

+4
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,7 @@
1+
/**
2+
* Copyright (C) 2018 Lightbend Inc. <https://www.lightbend.com>
3+
*/
4+
15
package com.lightbend.kafka.scala.streams
26

37
import org.apache.kafka.streams.kstream._

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

+4
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,7 @@
1+
/**
2+
* Copyright (C) 2018 Lightbend Inc. <https://www.lightbend.com>
3+
*/
4+
15
package com.lightbend.kafka.scala.streams
26

37
import org.apache.kafka.streams.kstream._

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

+4
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,7 @@
1+
/**
2+
* Copyright (C) 2018 Lightbend Inc. <https://www.lightbend.com>
3+
*/
4+
15
package com.lightbend.kafka.scala.streams
26

37
import ImplicitConversions._

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

+4
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,7 @@
1+
/**
2+
* Copyright (C) 2018 Lightbend Inc. <https://www.lightbend.com>
3+
*/
4+
15
package com.lightbend.kafka.scala.streams
26

37
import org.apache.kafka.streams.KeyValue

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

+4
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,7 @@
1+
/**
2+
* Copyright (C) 2018 Lightbend Inc. <https://www.lightbend.com>
3+
*/
4+
15
package com.lightbend.kafka.scala.streams
26

37
import org.apache.kafka.streams.kstream._

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

+4
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,7 @@
1+
/**
2+
* Copyright (C) 2018 Lightbend Inc. <https://www.lightbend.com>
3+
*/
4+
15
package com.lightbend.kafka.scala.streams
26

37
import org.apache.kafka.streams.kstream._

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

+4
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,7 @@
1+
/**
2+
* Copyright (C) 2018 Lightbend Inc. <https://www.lightbend.com>
3+
*/
4+
15
package com.lightbend.kafka.scala.streams
26

37
import java.util.regex.Pattern

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

+4
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,7 @@
1+
/**
2+
* Copyright (C) 2018 Lightbend Inc. <https://www.lightbend.com>
3+
*/
4+
15
package com.lightbend.kafka.scala.streams
26

37
import org.apache.kafka.streams.kstream._

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

+4
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,7 @@
1+
/**
2+
* Copyright (C) 2018 Lightbend Inc. <https://www.lightbend.com>
3+
*/
4+
15
package com.lightbend.kafka.scala.server
26

37
// Loosely based on Lagom implementation at

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

+4
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,7 @@
1+
/**
2+
* Copyright (C) 2018 Lightbend Inc. <https://www.lightbend.com>
3+
*/
4+
15
package com.lightbend.kafka.scala.server
26

37
import org.apache.kafka.clients.consumer.{ ConsumerConfig, KafkaConsumer }

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

+4
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,7 @@
1+
/**
2+
* Copyright (C) 2018 Lightbend Inc. <https://www.lightbend.com>
3+
*/
4+
15
package com.lightbend.kafka.scala.server
26

37
import org.apache.kafka.clients.producer.{ KafkaProducer, ProducerConfig, ProducerRecord, RecordMetadata }

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

+4
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,7 @@
1+
/**
2+
* Copyright (C) 2018 Lightbend Inc. <https://www.lightbend.com>
3+
*/
4+
15
package com.lightbend.kafka.scala.server
26

37
import org.apache.kafka.clients.consumer.ConsumerRecord

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

+4
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,7 @@
1+
/**
2+
* Copyright (C) 2018 Lightbend Inc. <https://www.lightbend.com>
3+
*/
4+
15
package com.lightbend.kafka.scala.server
26

37

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

+4
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,7 @@
1+
/**
2+
* Copyright (C) 2018 Lightbend Inc. <https://www.lightbend.com>
3+
*/
4+
15
package com.lightbend.kafka.scala.streams
26

37
import minitest.TestSuite

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

+5
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,8 @@
1+
/**
2+
* Copyright (C) 2018 Lightbend Inc. <https://www.lightbend.com>
3+
* Adapted from Confluent Inc. whose copyright is reproduced below.
4+
*/
5+
16
/*
27
* Copyright Confluent Inc.
38
*

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

+5
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,8 @@
1+
/**
2+
* Copyright (C) 2018 Lightbend Inc. <https://www.lightbend.com>
3+
* Adapted from Confluent Inc. whose copyright is reproduced below.
4+
*/
5+
16
/*
27
* Copyright Confluent Inc.
38
*

0 commit comments

Comments
 (0)