Hi all! Right now I am working on reactive streams connector to kafka. I am using new client and found strange behavior of commitAsync method which not calling callbacks at all at some cases.
I found, that callback calling is a part of handling of incoming messages. These messages are not fetching in background, but fetching during other activity (like fetching from topic). In the other hand there is no way to perform "blank" activity to fetch commit confirmation from Consumer. Right now if I message processing is depended on commit confirmation it is impossible to work in reactive way. Here it is very small example of problem - https://gist.github.com/13h3r/496e802afe65233b184a My questions are: - is it bug or design decision? - if it is not bug how I can write reactive consumer? Thanks!
