Как лучше всего написать продюсера Apache Kafka с устойчивым, но регулируемым выходом. Пример: производитель должен отправлять брокеру постоянные 1000 сообщений в секунду. Во время выполнения вывод должен быть настроен на 10 или 10000 сообщений...

У меня есть подписчик темы в lagom , как показано ниже fooService.fooTopic().subscribe .atLeastOnce( Flow[fooMsg].map { case fooMsg(_) => foo() case a => println(a) }.async.map{ _ => Done }...