fix minor issue

aliyun · Dec 27, 2018 · 06a6546 · 06a6546
1 parent e61b91e
commit 06a6546
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/tests/consumer_group_examples/sync_data_to_splunk.py b/tests/consumer_group_examples/sync_data_to_splunk.py
@@ -79,7 +79,7 @@ def process(self, log_groups, check_point_tracker):
             event.update(self.default_fields)
             if log.get(u"__topic__") == 'audit_log':
                 # suppose we only care about audit log
-                event['time'] = log['__time__']
+                event['time'] = log[u'__time__']
                 event['fields'] = {}
                 del log['__time__']
                 event['fields'].update(log)