Я хочу использовать кафку из приложения .net. Я создал производителя и потребителя, используя .net. Работает нормально.
Но я должен использовать Кафку для обработки файла в реальном времени. Так что я немного запутался. Какой должна быть архитектура, которой я должен следовать и как проектировать приложение kafka, чтобы оно было отказоустойчивым?
У меня есть несколько идентификаторов для файла, и файл может прийти в любое время, в любом количестве файлов. Поэтому я хочу использовать алгоритм хеширования, чтобы распределить нагрузку раздела kafka на другой раздел.
Я много раз гуглял, но не получал приложение или пример для использования этой функциональности в приложении .net.
Поэтому, пожалуйста, помогите мне в разработке и реализации желаемого алгоритма с использованием .net.
в основном у нас есть конечные точки (веб-сервисы), которые передаются клиенту, а клиент регулярно отправляет файл, у нас есть оконная служба, которая регулярно читает файл из базы данных и анализирует файл для дальнейшей обработки. все приложения находятся в .net. мы хотим поместить файл в kafka, а потребитель (оконный сервис) будет читать файл из kafka. Производитель будет нашим конечным точкам