[
https://issues.apache.org/jira/browse/APEXMALHAR-2121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15339102#comment-15339102
]
ASF GitHub Bot commented on APEXMALHAR-2121:
--------------------------------------------
GitHub user DT-Priyanka opened a pull request:
https://github.com/apache/apex-malhar/pull/323
APEXMALHAR-2121: Updating KafkaInputOperator to add emitTuple method with
access to more kafka parameters
Added emitTuple method with KafkaMessage as parameter. A user can override
this emitTuple to get access to more kafka parameters and choose what he wants
to emit along with kafka Message.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/DT-Priyanka/incubator-apex-malhar
APEXMALHAR-2121-kafka-emit-update
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/apex-malhar/pull/323.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #323
----
commit dc821843a8ff8064ef4bdba39adaa0b1595175ff
Author: Priyanka Gugale <[email protected]>
Date: 2016-06-20T07:25:12Z
APEXMALHAR-2121: Updating KafkaInputOperator to add emitTuple method with
access to more kafka parameters
----
> KafkaInputOperator emitTuple method should be able to emit more than just
> message
> ---------------------------------------------------------------------------------
>
> Key: APEXMALHAR-2121
> URL: https://issues.apache.org/jira/browse/APEXMALHAR-2121
> Project: Apache Apex Malhar
> Issue Type: Improvement
> Reporter: Priyanka Gugale
> Assignee: Priyanka Gugale
> Priority: Minor
>
> AbstractKafkaInputOperator in malhar-contrib operator had emitTuple method
> with parameter as "Message". User can't extend this method to access more
> kafka parameters other than messages.
> We should have a method to access to "KafkaMessage" so that user can choose
> from multiple fields which he/she wants to emit.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
