search

dehora / nakadi-java

🌀 Client library for the Nakadi Event Broker (examples: http://bit.ly/njc-examples, site: https://dehora.github.io/nakadi-java/)
MIT License
30 stars 19 forks source link

Stream Observer/Processor in a loop of onCompleted - onStart after token error. #337

Closed olayinkasf closed 6 years ago

olayinkasf commented 6 years ago

The observer was called in a loop of onCompleted - onStart for about an hour and afterwards there was an error obtaining access token 

2018-11-07 09:55:26.246 [] [] ERROR 14 --- [akadi-java-io-0] o.zalando.stups.tokens.AccessTokensBean : Token unavailable for service : nakadi-token
2018-11-07 09:55:26.253 [] [] ERROR 14 --- [akadi-java-io-0] NakadiClient : non_retryable_exception class org.zalando.stups.tokens.AccessTokenUnavailableException token expired
2018-11-07 09:55:26.254 [] [] WARN 14 --- [akadi-java-io-0] NakadiClient : stream_retry_not_retryable thread=nakadi-java-io-0 propagating AccessTokenUnavailableException, token expired

with no events received and the subscription remaining unassigned.

onStop was never called

version 0.11.0