[jira] [Commented] (APEXMALHAR-2154) Update kafka 0.9 input operator to use new CheckpointNotificationListener
[ https://issues.apache.org/jira/browse/APEXMALHAR-2154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15437102#comment-15437102 ] Siyuan Hua commented on APEXMALHAR-2154: I don't think so > Update kafka 0.9 input operator to use new CheckpointNotificationListener > - > > Key: APEXMALHAR-2154 > URL: https://issues.apache.org/jira/browse/APEXMALHAR-2154 > Project: Apache Apex Malhar > Issue Type: Improvement >Reporter: Siyuan Hua >Assignee: Chaitanya > Fix For: 3.5.0 > > > CheckpointListener interface has been deprecated. We should upgrade the > operator to use the new one -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (APEXMALHAR-2154) Update kafka 0.9 input operator to use new CheckpointNotificationListener
[ https://issues.apache.org/jira/browse/APEXMALHAR-2154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15433021#comment-15433021 ] Thomas Weise commented on APEXMALHAR-2154: -- Is there no behavior in this operator that can benefit from beforeCheckpoint? > Update kafka 0.9 input operator to use new CheckpointNotificationListener > - > > Key: APEXMALHAR-2154 > URL: https://issues.apache.org/jira/browse/APEXMALHAR-2154 > Project: Apache Apex Malhar > Issue Type: Improvement >Reporter: Siyuan Hua >Assignee: Chaitanya > Fix For: 3.5.0 > > > CheckpointListener interface has been deprecated. We should upgrade the > operator to use the new one -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (APEXMALHAR-2154) Update kafka 0.9 input operator to use new CheckpointNotificationListener
[ https://issues.apache.org/jira/browse/APEXMALHAR-2154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15429037#comment-15429037 ] ASF GitHub Bot commented on APEXMALHAR-2154: Github user asfgit closed the pull request at: https://github.com/apache/apex-malhar/pull/373 > Update kafka 0.9 input operator to use new CheckpointNotificationListener > - > > Key: APEXMALHAR-2154 > URL: https://issues.apache.org/jira/browse/APEXMALHAR-2154 > Project: Apache Apex Malhar > Issue Type: Improvement >Reporter: Siyuan Hua >Assignee: Chaitanya > > CheckpointListener interface has been deprecated. We should upgrade the > operator to use the new one -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (APEXMALHAR-2154) Update kafka 0.9 input operator to use new CheckpointNotificationListener
[ https://issues.apache.org/jira/browse/APEXMALHAR-2154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15426497#comment-15426497 ] ASF GitHub Bot commented on APEXMALHAR-2154: GitHub user chaithu14 opened a pull request: https://github.com/apache/apex-malhar/pull/373 APEXMALHAR-2154 Update the Kafka Input Operator to use CheckpointNotificationListener You can merge this pull request into a Git repository by running: $ git pull https://github.com/chaithu14/incubator-apex-malhar APEXMALHAR-2154 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/apex-malhar/pull/373.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 #373 commit 9d15fe29287697ff2b660e637c495d76a01ab910 Author: chaitanyaDate: 2016-08-18T07:23:40Z APEXMALHAR-2154 Update the Kafka Input Operator to use CheckpointNotificationListener > Update kafka 0.9 input operator to use new CheckpointNotificationListener > - > > Key: APEXMALHAR-2154 > URL: https://issues.apache.org/jira/browse/APEXMALHAR-2154 > Project: Apache Apex Malhar > Issue Type: Improvement >Reporter: Siyuan Hua >Assignee: Chaitanya > > CheckpointListener interface has been deprecated. We should upgrade the > operator to use the new one -- This message was sent by Atlassian JIRA (v6.3.4#6332)