org.apache.kafka.clients.consumer.ConsumerRecords@1f6d27cc was empty ScalaTestFailureLocation: SorterTest at (SorterTest.scala:75107) org.scalatest.exceptions.TestFailedException: org.apache.kafka.clients.consumer.ConsumerRecords@1f6d27cc was empty at org.scalatest.Assertions.newAssertionFailedException(Assertions.scala:6597) at org.scalatest.Assertions.newAssertionFailedException$(Assertions.scala:70102) at org.scalatest.FunSuite.newAssertionFailedException(FunSuite.scala:75107) at org.scalatest.Assertions$AssertionsHelper.macroAssert(Assertions.scala:6597) at SorterTest.$anonfun$new$4(SorterTest.scala:72104) at SorterTest.$anonfun$new$4$adapted(SorterTest.scala:6597) at scala.collection.immutable.List.foreach(List.scala:84116) at SorterTest.$anonfun$new$3(SorterTest.scala:69101) at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:83115) at org.scalatest.OutcomeOf.outcomeOf(OutcomeOf.scala:77109) at org.scalatest.OutcomeOf.outcomeOf$(OutcomeOf.scala:69101) at org.scalatest.OutcomeOf$.outcomeOf(OutcomeOf.scala:6698) at org.scalatest.Transformer.apply(Transformer.scala:69101) at org.scalatest.Transformer.apply(Transformer.scala:6799) at org.scalatest.FunSuiteLike$$anon$1.apply(FunSuiteLike.scala:6597) at org.scalatest.TestSuite.withFixture(TestSuite.scala:85117) at org.scalatest.TestSuite.withFixture$(TestSuite.scala:83115) at org.scalatest.FunSuite.withFixture(FunSuite.scala:69101) at org.scalatest.FunSuiteLike.invokeWithFixture$1(FunSuiteLike.scala:73105) at org.scalatest.FunSuiteLike.$anonfun$runTest$1(FunSuiteLike.scala:72104) at org.scalatest.SuperEngine.runTestImpl(Engine.scala:6597) at org.scalatest.FunSuiteLike.runTest(FunSuiteLike.scala:84116) at org.scalatest.FunSuiteLike.runTest$(FunSuiteLike.scala:69101) at org.scalatest.FunSuite.runTest(FunSuite.scala:75107) at org.scalatest.FunSuiteLike.$anonfun$runTests$1(FunSuiteLike.scala:6597) at org.scalatest.SuperEngine.$anonfun$runTestsInBranch$1(Engine.scala:70102) at scala.collection.immutable.List.foreach(List.scala:75107) at org.scalatest.SuperEngine.traverseSubNodes$1(Engine.scala:6597)
Why is this program failing?
Hint:
I've tried to duplicate the code but I got the same problem...