Я новичок в kafka, мне нужна помощь в разработке подхода для работы с конкретным сценарием.
У меня есть две темы kafka, ПОЛЬЗОВАТЕЛИ и СОТРУДНИКИ.
USERS
key: userId
value: [
login: parkash,
firstname: parkash,
employee: 1
]
and
EMPLOYEES.
key: employeeId
value: [
firstname: parkash
lastname: kumar
]
У меня есть методкоторый исключает employee_id в качестве параметра и возвращает данные соответственно.
Я вхожу в приложение через идентификатор входа, указанный в темах USERS.Я хочу получить данные для зарегистрированного пользователя, но мой метод принимает employee_id в качестве параметра.Поэтому из-за этого мне нужно сначала получить идентификатор сотрудника из темы USERS, но здесь login_id также не является ключом в теме USERS, а является частью значения.Итак, как мне пойти на это.
Должен ли я сначала получить все данные из раздела USERS в магазине, затем выполнить итерацию по всему магазину, проверить значение входа в систему с предоставленным идентификатором входа и вернуть идентификатор сотрудника для объекта.Затем я должен найти идентификатор этого сотрудника в этой теме РАБОТНИКА.Правильно ли я здесь, если да, как лучше это реализовать?Может ли такой подход привести к проблемам с производительностью, так как я повторяюсь по всему магазину.
Я просто прошу подход (не любую реализацию), чтобы лучше понять потоки кафки, такие как создание магазина, манипулирование потоками кафки.