Gerrick Bivins

Kafka consumer doesn't use context from ConsumerRecord Headers

4

I'm using [Alpakka](https://doc.akka.io/docs/alpakka-kafka/current/index.html) in a scala service to subscribe to topics. I'm seeing that the `ConsumerRecord`s that are being processed in my `Flow` have the correct header values for `x-datadog-trace-id`...

In a scala service that uses JDK 16 (adoptopenjdk/openjdk16:jre-16.0.1_9-alpine) I'm seeing the following exception : ```bash [dd.trace 2022-02-16 21:02:18:305 +0000] [BillingEventProcessor-akka.actor.default-dispatcher-25] DEBUG datadog.trace.bootstrap.ExceptionLogger - Failed to handle exception in instrumentation...