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 } }