Hi everyone, I'd like to discuss 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 her: https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=188746244 Any comments and feedback are welcomed. Thank you. Luke
