Remove encoding check (#279)

* remove encoding check

* remove explicit string escaping when failure to encode as json
diff --git a/provider/consumer.py b/provider/consumer.py
index 3819072..4bf62cf 100644
--- a/provider/consumer.py
+++ b/provider/consumer.py
@@ -450,13 +450,6 @@
         return offsets
 
     def __encodeMessageIfNeeded(self, value):
-        # let's make sure whatever data we're getting is utf-8 encoded
-        try:
-            value = value.encode('utf-8')
-        except UnicodeDecodeError:
-            logging.warn('[{}] Value contains non-unicode bytes. Replacing invalid bytes.'.format(self.trigger))
-            value = unicode(value, errors='replace').encode('utf-8')
-
         if self.encodeValueAsJSON:
             try:
                 parsed = json.loads(value)
@@ -465,7 +458,6 @@
             except ValueError:
                 # no big deal, just return the original value
                 logging.warn('[{}] I was asked to encode a message as JSON, but I failed.'.format(self.trigger))
-                value = "\"{}\"".format(value)
                 pass
         elif self.encodeValueAsBase64:
             try: