Description
CallingĀ Consumer.position() from KStreamsĀ for computing the offset that must be committed suffers from a race condition so that by the time we want to commit, the position may be gone.
CallingĀ Consumer.position() from KStreamsĀ for computing the offset that must be committed suffers from a race condition so that by the time we want to commit, the position may be gone.