- Improved
consumer.consume()to return alistinstead of afilter() - Removed handling of
signal.SIGINT - Fixed logging error in
on_errorcallback - Added logging when
on_successoron_errorraise an exception
consumer.consume() to return a list instead of a filter()signal.SIGINTon_error callbackon_success or on_error raise an exception