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 9a96a811c31..f523e2057e5 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 } }