В рамках решения задания были созданы producer и consumer, которые записывают и считывают числа из Kafka соответственно. Ко всем числам применяется алгоритм FizzBuzz, а результат записывается в текстовый файл.
Описание:
-
MyProducer - класс, отвечающий за producer и имеющий метод для отправки чисел;
-
MainProducer - класс, в методе main которого создаётся экземпляр MyProducer и вызывается метод отправки миллиона чисел;
-
MyConsumer - класс, отвечающий за consumer и обрабатывающий входящие числа в соответствии с алгоритмом FizzBuzz;
-
MainConsumer - класс, в методе main которого создаётся экземпляр MyConsumer и считываются числа;
Примечание: файл docker-compose.yml использовался для запуска Apache Kafka в docker контейнере.