[streaming] connectors logging and error handling fixed