Method: NewRelic::Agent::Instrumentation::Rdkafka#each_with_new_relic

Defined in:
lib/new_relic/agent/instrumentation/rdkafka/instrumentation.rb

#each_with_new_relic(message) ⇒ Object

[View source]

35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
 
# File 'lib/new_relic/agent/instrumentation/rdkafka/instrumentation.rb', line 35

def each_with_new_relic(message)
  NewRelic::Agent.record_instrumentation_invocation(INSTRUMENTATION_NAME)

  headers = message&.headers || {}
  topic_name = message&.topic

  NewRelic::Agent::Messaging.wrap_message_broker_consume_transaction(
    library: MESSAGING_LIBRARY,
    destination_type: :topic,
    destination_name: topic_name,
    headers: headers,
    action: :consume
  ) do
    create_kafka_metrics(action: CONSUME, topic: topic_name)
    yield
  end
end