Handling DataWriter exceptions in DataConsumer consume