diff --git a/lib/deimos/logging.rb b/lib/deimos/logging.rb
index f492f3b..a8f7083 100644
--- a/lib/deimos/logging.rb
+++ b/lib/deimos/logging.rb
@@ -3,7 +3,11 @@ module Logging
     class << self
 
       def log_add(method, msg)
-        Karafka.logger.tagged('Deimos') do |logger|
+        if Karafka.logger.respond_to?(:tagged)
+          Karafka.logger.tagged('Deimos') do |logger|
+            logger.send(method, msg.to_json)
+          end
+        else
           logger.send(method, msg.to_json)
         end