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

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

Reply via email to