We have an integration test that uses Akka Kafka to publish messages to a topic, that are then consumed by a library under test that also uses Akka Kafka.
Because autoOffsetReset is "latest", we are trying to defer publishing the test messages until the consumer is "ready". The consumer stream is monitored by a host actor, so we have been able to send it a "stream started" message after run() is called, and then the test (with host probe) can do an expectMsg for that message, followed by an expectNoMsg() before starting to publish messages. But this seems to be a bit hokey/fragile. Any ideas for a better way? -- >>>>>>>>>> Read the docs: http://akka.io/docs/ >>>>>>>>>> Check the FAQ: >>>>>>>>>> http://doc.akka.io/docs/akka/current/additional/faq.html >>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user --- You received this message because you are subscribed to the Google Groups "Akka User List" group. To unsubscribe from this group and stop receiving emails from it, send an email to akka-user+unsubscr...@googlegroups.com. To post to this group, send email to akka-user@googlegroups.com. Visit this group at https://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
