nl: noop is the default behavior , which means that kafka will internally handle partition assignment . if you wish to do manual partition management , you must provide an implementation of this method that will check with kafka for any changes and call the consumerrebalancelistener from subscribe to inform the rest of the system of those changes . concode_field_sep long serialVersionUID concode_field_sep String getTopicsString concode_elem_sep void subscribe
code: void function ( ) { }