update onTimeInQueue

Author: rarguelloF

dd-java-agent/instrumentation/kafka-clients-0.11/src/main/java/datadog/trace/instrumentation/kafka_clients/KafkaDecorator.java

@@ -144,6 +144,7 @@ public void onTimeInQueue(final AgentSpan span, final ConsumerRecord record) {
     if (record != null) {
       String topic = record.topic() == null ? "kafka" : record.topic();
       span.setResourceName(topic);
+      span.setTag(MESSAGING_DESTINATION_NAME, topic);
       if (Config.get().isMessageBrokerSplitByDestination()) {
         span.setServiceName(topic);
       }

dd-java-agent/instrumentation/kafka-clients-3.8/src/main/java17/datadog/trace/instrumentation/kafka_clients38/KafkaDecorator.java

@@ -144,6 +144,7 @@ public void onTimeInQueue(final AgentSpan span, final ConsumerRecord record) {
     if (record != null) {
       String topic = record.topic() == null ? "kafka" : record.topic();
       span.setResourceName(topic);
+      span.setTag(MESSAGING_DESTINATION_NAME, topic);
       if (Config.get().isMessageBrokerSplitByDestination()) {
         span.setServiceName(topic);
       }