[kafka] 02/02: Update cherry-pick to fit 2.8 testing style for scala

[bbejeck]

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

bbejeck pushed a commit to branch 2.8
in repository https://gitbox.apache.org/repos/asf/kafka.git

commit 74d2f8abb4c8b9ec74578cd492ad4ada152458f3
Author: bill <bbej...@gmail.com>
AuthorDate: Thu Jun 24 12:54:59 2021 -0400

    Update cherry-pick to fit 2.8 testing style for scala
---
 .../scala/org/apache/kafka/streams/scala/kstream/KStreamTest.scala   | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)

diff --git 
a/streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/kstream/KStreamTest.scala
 
b/streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/kstream/KStreamTest.scala
index d7e7e9a..34fcd14 100644
--- 
a/streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/kstream/KStreamTest.scala
+++ 
b/streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/kstream/KStreamTest.scala
@@ -451,8 +451,7 @@ class KStreamTest extends FlatSpec with Matchers with 
TestDriver {
     transformNode.name() shouldBe "my-name"
   }
 
-  @Test
-  def testSettingNameOnStream(): Unit = {
+  "Setting a name for a pattern source" should "pass the name to the topology" 
in {
     val builder = new StreamsBuilder()
     val topicsPattern = "t-[A-Za-z0-9-].suffix"
     val sinkTopic = "sink"
@@ -466,7 +465,7 @@ class KStreamTest extends FlatSpec with Matchers with 
TestDriver {
     import scala.jdk.CollectionConverters._
 
     val streamNode = 
builder.build().describe().subtopologies().asScala.head.nodes().asScala.head
-    assertEquals("my-fancy-name", streamNode.name())
+    streamNode.name() shouldBe "my-fancy-name"
   }
 
 }