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

Commit fba1053

Browse files
authored
Merge pull request #32 from lightbend/issue-31
Fixes issue #31
2 parents 76574ae + fb9493d commit fba1053

File tree

2 files changed

+12
-1
lines changed

2 files changed

+12
-1
lines changed

build.sbt

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,7 @@ name := "kafka-streams-scala"
44

55
organization := "com.lightbend"
66

7-
version := "0.1.0"
7+
version := "0.2.0-SNAPSHOT"
88

99
scalaVersion := Versions.Scala_2_12_Version
1010

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

Lines changed: 11 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -56,6 +56,17 @@ class StreamsBuilderS {
5656
def globalTable[K, V](topic: String): GlobalKTable[K, V] =
5757
inner.globalTable(topic)
5858

59+
def globalTable[K, V](topic: String, consumed: Consumed[K, V]) : GlobalKTable[K, V] =
60+
inner.globalTable(topic, consumed)
61+
62+
def globalTable[K, V](topic: String, consumed: Consumed[K, V],
63+
materialized: Materialized[K, V, KeyValueStore[Bytes, Array[Byte]]]): GlobalKTable[K, V] =
64+
inner.globalTable(topic, consumed, materialized)
65+
66+
def globalTable[K, V](topic: String,
67+
materialized: Materialized[K, V, KeyValueStore[Bytes, Array[Byte]]]): GlobalKTable[K, V] =
68+
inner.globalTable(topic, materialized)
69+
5970
def addStateStore(builder: StoreBuilder[_ <: StateStore]): StreamsBuilder = inner.addStateStore(builder)
6071

6172
def addGlobalStore(storeBuilder: StoreBuilder[_ <: StateStore], topic: String, sourceName: String, consumed: Consumed[_, _], processorName: String, stateUpdateSupplier: ProcessorSupplier[_, _]): StreamsBuilder =

0 commit comments

Comments
 (0)