This is an automated email from the ASF dual-hosted git repository.

bbejeck 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 c74acb2  MINOR: Remove line for testing repartition topic name (#6488)
c74acb2 is described below

commit c74acb24eb1da5d16cc2721a63931cd87f79ec66
Author: Bill Bejeck <bbej...@gmail.com>
AuthorDate: Sun Mar 24 12:47:58 2019 -0400

    MINOR: Remove line for testing repartition topic name (#6488)
    
    With KIP-307 joined.name() is deprecated plus we don't need to test for 
repartition topic names.
    Reviewers: Matthias J. Sax <mj...@apache.org>
---
 .../test/scala/org/apache/kafka/streams/scala/kstream/JoinedTest.scala   | 1 -
 1 file changed, 1 deletion(-)

diff --git 
a/streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/kstream/JoinedTest.scala
 
b/streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/kstream/JoinedTest.scala
index 9a96a81..f523e20 100644
--- 
a/streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/kstream/JoinedTest.scala
+++ 
b/streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/kstream/JoinedTest.scala
@@ -42,6 +42,5 @@ class JoinedTest extends FlatSpec with Matchers {
     joined.keySerde.getClass shouldBe Serdes.String.getClass
     joined.valueSerde.getClass shouldBe Serdes.Long.getClass
     joined.otherValueSerde.getClass shouldBe Serdes.Integer.getClass
-    joined.name() shouldBe repartitionTopicName
   }
 }

Reply via email to