Method: Karafka::Instrumentation::StdoutListener#on_params_params_deserialize_error

Defined in:
lib/karafka/instrumentation/stdout_listener.rb

#on_params_params_deserialize_error(event) ⇒ Object

Logs unsuccessful deserialization attempts of incoming data

Parameters:

  • event (Dry::Events::Event) —

    event details including payload



54
55
56
57
58
 
# File 'lib/karafka/instrumentation/stdout_listener.rb', line 54

def on_params_params_deserialize_error(event)
  topic = event[:caller].metadata.topic
  error = event[:error]
  error "Params deserialization error for #{topic} topic: #{error}"
end