[jira] [Commented] (BEAM-4038) Support Kafka Headers in KafkaIO

2018-10-02 Thread Alexey Romanenko (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-4038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635696#comment-16635696 ] Alexey Romanenko commented on BEAM-4038: [~rangadi] Thank you. Do you know if we h

[jira] [Commented] (BEAM-4038) Support Kafka Headers in KafkaIO

2018-10-01 Thread Raghu Angadi (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-4038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16634641#comment-16634641 ] Raghu Angadi commented on BEAM-4038: Sounds good. I will close this for now. We can ad

[jira] [Commented] (BEAM-4038) Support Kafka Headers in KafkaIO

2018-10-01 Thread Geet Kumar (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-4038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16634083#comment-16634083 ] Geet Kumar commented on BEAM-4038: -- [~rangadi] > This is not yet a requested feature. We

[jira] [Commented] (BEAM-4038) Support Kafka Headers in KafkaIO

2018-10-01 Thread Alexey Romanenko (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-4038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16633920#comment-16633920 ] Alexey Romanenko commented on BEAM-4038: [~gkumar7] Hi, are you going to continue

[jira] [Commented] (BEAM-4038) Support Kafka Headers in KafkaIO

2018-07-14 Thread Geet Kumar (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-4038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16544317#comment-16544317 ] Geet Kumar commented on BEAM-4038: -- Apologies for the very late reply on this! I will see

[jira] [Commented] (BEAM-4038) Support Kafka Headers in KafkaIO

2018-07-12 Thread Raghu Angadi (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-4038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16541977#comment-16541977 ] Raghu Angadi commented on BEAM-4038: It is not a blocker. I removed 'Fix Version'. The

[jira] [Commented] (BEAM-4038) Support Kafka Headers in KafkaIO

2018-07-11 Thread Pablo Estrada (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-4038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16540677#comment-16540677 ] Pablo Estrada commented on BEAM-4038: - Hi all, what's the plan for this issue? Is it a

[jira] [Commented] (BEAM-4038) Support Kafka Headers in KafkaIO

2018-04-30 Thread Raghu Angadi (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-4038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16459481#comment-16459481 ] Raghu Angadi commented on BEAM-4038: In Kafka {{ConsumerRecord}} and {{ProducerRecord}}

[jira] [Commented] (BEAM-4038) Support Kafka Headers in KafkaIO

2018-04-30 Thread Geet Kumar (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-4038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16459432#comment-16459432 ] Geet Kumar commented on BEAM-4038: -- {quote} How about adding {{KafkaIO.writeRecords()}} wh

[jira] [Commented] (BEAM-4038) Support Kafka Headers in KafkaIO

2018-04-29 Thread Raghu Angadi (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-4038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16458325#comment-16458325 ] Raghu Angadi commented on BEAM-4038: The interfaces with function call backs are proble

[jira] [Commented] (BEAM-4038) Support Kafka Headers in KafkaIO

2018-04-27 Thread Geet Kumar (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-4038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16457247#comment-16457247 ] Geet Kumar commented on BEAM-4038: -- [~rangadi] regarding adding kafka headers, a simple ap

[jira] [Commented] (BEAM-4038) Support Kafka Headers in KafkaIO

2018-04-11 Thread Raghu Angadi (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-4038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16434033#comment-16434033 ] Raghu Angadi commented on BEAM-4038: Thanks. Will be happy to review. We need to make s

[jira] [Commented] (BEAM-4038) Support Kafka Headers in KafkaIO

2018-04-10 Thread Geet Kumar (JIRA)
[ 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

[jira] [Commented] (BEAM-4038) Support Kafka Headers in KafkaIO

2018-04-10 Thread Raghu Angadi (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-4038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16432658#comment-16432658 ] Raghu Angadi commented on BEAM-4038: Reader support * I think this more critical and t