diff --git a/lib/manageiq/messaging/kafka/common.rb b/lib/manageiq/messaging/kafka/common.rb
index 7859e67..dd02037 100644
--- a/lib/manageiq/messaging/kafka/common.rb
+++ b/lib/manageiq/messaging/kafka/common.rb
@@ -116,7 +116,7 @@ def message_header_keys
 
         def parse_message_headers(headers)
           return [nil, nil, nil] unless headers.kind_of?(Hash)
-          headers.values_at(*message_header_keys)
+          headers.with_indifferent_access.values_at(*message_header_keys)
         end
 
         def event_header_keys
@@ -125,7 +125,7 @@ def event_header_keys
 
         def parse_event_headers(headers)
           return [nil, nil] unless headers.kind_of?(Hash)
-          headers.values_at(*event_header_keys)
+          headers.with_indifferent_access.values_at(*event_header_keys)
         end
       end
     end