file.d
file.d copied to clipboard
Fix franz offset out
We'have got error OFFSET_OUT_OF_RANGE and reset of offsets
Improvments for fix this issue:
- goroutine per kafka partition consuming
- fix timestamp in producer