Hi everyone, I'd like to start a vote for the following proposal to add Consumer#peek for debugging/tuning.
The main purpose for Consumer#peek is to allow users: 1. peek what records existed at broker side and not increasing the position offsets. 2. throw exceptions when there is connection error existed between consumer and broker (or other exceptions will be thrown by "poll") Detailed description can be found here: https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=188746244 Thank you Luke