Hi I am not sure if it is an existing bug but ManualParitionNamedSubcription fails to initialize the spout because listener.onPartitionsAssigned(newAssignment) is never invoked. It requires a simple change which I have done locally. If this has already been fixed, please let me know.
Regards Chandan
