You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "Fil Karnicki (Jira)" <ji...@apache.org> on 2022/03/12 21:05:00 UTC

[jira] [Created] (FLINK-26617) Pass Kafka headers to remote functions and egresses

Fil Karnicki created FLINK-26617:
------------------------------------

             Summary: Pass Kafka headers to remote functions and egresses
                 Key: FLINK-26617
                 URL: https://issues.apache.org/jira/browse/FLINK-26617
             Project: Flink
          Issue Type: Improvement
          Components: Stateful Functions
            Reporter: Fil Karnicki


Typically OpenTelemetry (FLINK-22390) tracing spans get passed in kafka headers. We could be passing not only the Kafka ConsumerRecord value, but also the headers to remote functions, if the user configures their kafka ingress to do so

Similarly, kafka egresses could be configurable so that headers get passed on via the KafkaProducerRecord proto to kafka



--
This message was sent by Atlassian Jira
(v8.20.1#820001)