[ https://issues.apache.org/jira/browse/BEAM-4038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16433257#comment-16433257 ]
Geet Kumar commented on BEAM-4038: ---------------------------------- [~rangadi], so far yes the changes required for Reader support were minimal. Just need to perform a few additional tests and should be able to create a pull request. Regarding writer support, I feel users should be writing KafkaRecords as well, though the change is more of a "good to have" as currently users could embed KafkaRecords in KV<>. > Support Kafka Headers in KafkaIO > -------------------------------- > > Key: BEAM-4038 > URL: https://issues.apache.org/jira/browse/BEAM-4038 > Project: Beam > Issue Type: New Feature > Components: io-java-kafka > Reporter: Geet Kumar > Assignee: Raghu Angadi > Priority: Minor > > Headers have been added to Kafka Consumer/Producer records (KAFKA-4208). The > purpose of this JIRA is to support this feature in KafkaIO. > -- This message was sent by Atlassian JIRA (v7.6.3#76005)