Roiocam commented on code in PR #105:
URL:
https://github.com/apache/incubator-pekko-projection/pull/105#discussion_r1495290031
##########
kafka-test/src/test/scala/org/apache/pekko/projection/kafka/internal/KafkaSourceProviderImplSpec.scala:
##########
@@ -109,6 +110,12 @@ class KafkaSourceProviderImplSpec extends
ScalaTestWithActorTestKit with LogCapt
records.count(_.partition() == tp1.partition()) shouldBe 5
}
+ // because source push to handle(probe) before sinkProbe request pull,
it made probe cache random one record
+ val eagerMessage = probe.receiveMessage()
Review Comment:
It's kind of like https://github.com/akka/akka-projection/issues/462, i
won't say this is best solution.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: notifications-unsubscr...@pekko.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: notifications-unsubscr...@pekko.apache.org
For additional commands, e-mail: notifications-h...@pekko.apache.org
