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

Removes duplicate Observer onStart call. #272

Closed dehora closed 7 years ago

dehora commented 7 years ago

This replaces the onStart call when the consumer processor is setup with a new onBegin method. The onStart should be called every time the processor retries, but onBegin just once, avoiding a double call the first time the processor spins up.