Pull to refresh
14
0
Send message

Сомневаюсь, что max.poll.records влияет на кол-во сетевых обращений. Из доки https://www.conduktor.io/kafka/kafka-consumer-important-settings-poll-and-internal-threads-behavior/

This setting does not impact the underlying fetching behavior. The consumer will cache the records from each fetch request and returns them incrementally from each poll.
Может конечно я что-то не так поняла

в реальности чем больше работаешь, тем больше это все забывается.
А в ссылке на курс только SQL.

а где в коде задается число консьюмеров в группе? Читается в 4 потока, но не очень понятно, как это связано с числом консьюмеров в группе.

Можно проще: попробуйте пост соблюдать. Узнаешь кучу новых вкусных блюд (из других компонентов), так что страдать не приходится, а калорий меньше.

все равно не понятно: а почему связывание по месту исполнения не дает выполниться аннотации около method2 ?

Значит Альфа и Газпром не годятся - под (частичными) санкциями?

Какие mock-и использовали для подготовки, enthuware подходит? (Просто ничего больше не нашла)

Ещё если много серверов поставить, то с сессией проблема возникнет, хотя и решаемая не только с помощью stateless токена. Но исторически отказ от сессий и сдвиг к stateless rest именно из-за проблемы горизонтального масштабирования возник, если правильно понимаю...

а вот эти две очереди в разных тредах только для того, чтобы /notify можно было выполнить через n секунд? Если же на нашем севере нет долгих обработок, то все можно в одном треде делать, получается? (несмотря на то, что сообщения от разных людей могут быть)

для расширения функциональности телеграма

Спасибо, полезно. Но почему для клиента использован spring-boot-starter-oauth2-client, а для сервера ресурсов spring-security-oauth2-resource-server? (есть spring-boot-starter-oauth2-resource-server; он новее, как я понимаю)
Старая статья, но Selenium 3, как я понимаю, не вышел?
И Selenium Server — это то, что в папке github.com/SeleniumHQ/selenium/tree/trunk/java/server?
рискну предположить — «не поддерживается» это означает «нельзя при Form Login вместо сессии использовать JWT из cookie»?

Да. Не из cookie, а из Authorization header, но не суть…
Просто все знают, что для SPA нужен stateless токен, начинаешь искать подходящий. А оказывается, надо Authorization Server развернуть. ПС точнее, не stateless токен, а stateless API, jwt-токен то как раз может хранить состояние.
Спасибо за ответы!
Еще такой вопрос: а какую аутентификацию (не обязательно OAuth2) оптимально использовать для REST API, если оно и для браузерного SPA-приложений, и, в перспективе, для мобильного? При этом чтобы масштабировать горизонтально было возможно (то есть stateless). Из коробки JWT в Spring Security не поддерживается (почему?). Есть Simple Hash-Based Token Approach, но звучит так, что он просто нужен для сохранения состояния между сессиями. Это так, или именно его вместо JWT надо использовать?
2. То есть сервер авторизации выдал JWT токен (access token) с использованием секретного ключа, этот же ключ есть на сервере ресурсов. И с помощью него сервер ресурсов проверяет JWT на подлинность, не дергая сервер авторизации. Правильно понимаю? В Spring Security OAuth 2 сервер авторизации и сервер ресурсов так работают?
И еще вопрос: можно ли задать свой OAuth2AccessTokenResponseClient только для одного провайдера (для vk, токен тоже нестандартно выдает). Если делать как тут, то ломаются остальные провайдеры (github и прочие)
http.oauth2Login().tokenEndpoint().accessTokenResponseClient(accessTokenResponseClient());
— Своя реализация UserService не просто не нужна, а даже вредна.

А как быть, если ВКонтакте на запрос юзера (по user-info-uri) не Map возвращает, а сложную структуру c массивом из одного элемента — который и есть авторизовавшийся юзер:

    response: {
         [
            { 
                 id: "123",
                 first_name: "имя"
                 ...
             }
         ]
   }
}

DefaultOAuth2UserService, как я понимаю, только простейший объект без вложенности парсит.
Пробую создать VkOAuth2User implements OAuth2User и добавить в конфигурацию, как ниже. Это правильное направление, или куда копать?
http.oauth2Login(oauth2Login ->
                oauth2Login
                        .userInfoEndpoint(userInfoEndpoint ->
                                userInfoEndpoint
                                        .customUserType(VkOAuth2User.class, "vk")

                        )
Да, грязная запись именно это (т.е. сценарий 1 в комменте выше " when data that has been updated by one transaction is overwritten by another transaction, before the first transaction is either committed or rolled back")

И с определением потерянного обновления согласна. Но случаться то оно может, почему нет? (А в таблице в статье показано, что нет — как будто это самый недопустимый феномен).

На уровне Read Commited возможен Lost Update, а Repeatable Read его предотвращает. vladmihalcea.com/a-beginners-guide-to-database-locking-and-the-lost-update-phenomena

Information

Rating
Does not participate
Registered
Activity