This is an automated email from the ASF dual-hosted git repository.
guozhang pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new ac9de82 MINOR: Use Set instead of List for multiple topics (#5024)
ac9de82 is described below
commit ac9de822b2164426a6ebfce62ab0ad10766c2cad
Author: Joan Goyeau <[email protected]>
AuthorDate: Thu May 17 16:44:50 2018 +0100
MINOR: Use Set instead of List for multiple topics (#5024)
Debasish Ghosh <[email protected]>, Guozhang Wang <[email protected]>
---
.../src/main/scala/org/apache/kafka/streams/scala/StreamsBuilder.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/StreamsBuilder.scala
b/streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/StreamsBuilder.scala
index 3f58dd3..718de10 100644
---
a/streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/StreamsBuilder.scala
+++
b/streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/StreamsBuilder.scala
@@ -70,7 +70,7 @@ class StreamsBuilder(inner: StreamsBuilderJ = new
StreamsBuilderJ) {
* @see #stream(String)
* @see `org.apache.kafka.streams.StreamsBuilder#stream`
*/
- def stream[K, V](topics: List[String])(implicit consumed: Consumed[K, V]):
KStream[K, V] =
+ def stream[K, V](topics: Set[String])(implicit consumed: Consumed[K, V]):
KStream[K, V] =
inner.stream[K, V](topics.asJava, consumed)
/**
--
To stop receiving notification emails like this one, please contact
[email protected].
