[kafka] branch trunk updated: MINOR: Use Set instead of List for multiple topics (#5024)

[gu...@apache.org]

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 <jo...@goyeau.com>
AuthorDate: Thu May 17 16:44:50 2018 +0100

    MINOR: Use Set instead of List for multiple topics (#5024)
    
    Debasish Ghosh <dg...@acm.org>, Guozhang Wang <gu...@confluent.io>
---
 .../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
guozhang@apache.org.