Я использую сторонний сервис, который пользователи должны аутентифицировать в нашем приложении. Например, допустим, что наше приложение использует API Google в реальном времени, и для того, чтобы наши пользователи могли его использовать, Google отображает экран согласия, и им необходимо войти в свои учетные записи Google, а мы получаем токены доступа. Теперь я хочу как-то использовать производителя для получения данных от ВСЕХ пользователей, которые аутентифицировали указанный API Google. Это потребует подключения к нескольким конечным точкам, таким как:
https://www.api.com/getdata?accesstoken=user1...
https://www.api.com/getdata?accesstoken=user2...
and so on.
. Это позволит мне получить все данные, поступающие от производителя Kafka. Но я не знаю, какой была бы правильная настройка для этого.
Гипотетически, я могу просто создать несколько производителей для каждого проверенного токена доступа и направить все эти данные в одну топи c, но это не так. Звучит разумно или масштабируемо. Есть ли способ, чтобы один обработчик получал только маркеры доступа из базы данных и самостоятельно подключался к каждой конечной точке? или есть лучший способ сделать что-то подобное?
Большое спасибо!