You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@nifi.apache.org by olegz <gi...@git.apache.org> on 2016/07/20 16:19:50 UTC

[GitHub] nifi pull request #687: NIFI-2298 added Kafka consume attributes to a FlowFi...

GitHub user olegz opened a pull request:

    https://github.com/apache/nifi/pull/687

    NIFI-2298 added Kafka consume attributes to a FlowFile

    

You can merge this pull request into a Git repository by running:

    $ git pull https://github.com/olegz/nifi NIFI-2298

Alternatively you can review and apply these changes as the patch at:

    https://github.com/apache/nifi/pull/687.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 #687
    
----
commit f0b62d477882b65fba84b94a0e5067749a5f6ee4
Author: Oleg Zhurakousky <ol...@suitcase.io>
Date:   2016-07-20T16:18:55Z

    NIFI-2298 added Kafka consume attributes to a FlowFile

----


---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---

[GitHub] nifi pull request #687: NIFI-2298 added Kafka consume attributes to a FlowFi...

Posted by asfgit <gi...@git.apache.org>.
Github user asfgit closed the pull request at:

    https://github.com/apache/nifi/pull/687


---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---

[GitHub] nifi issue #687: NIFI-2298 added Kafka consume attributes to a FlowFile

Posted by xmlking <gi...@git.apache.org>.
Github user xmlking commented on the issue:

    https://github.com/apache/nifi/pull/687
  
    @olegz does consumeKafka support back pressure ?
    I would like to add ControlRate processor after consumeKafka to reduce the speed of messages pumped into nifi flow.



---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---

[GitHub] nifi issue #687: NIFI-2298 added Kafka consume attributes to a FlowFile

Posted by olegz <gi...@git.apache.org>.
Github user olegz commented on the issue:

    https://github.com/apache/nifi/pull/687
  
    @xmlking Back Pressure is the function of all processors so there is nothing specific required in ConsumeKafka to handle it. Does that answer your question?


---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---

[GitHub] nifi issue #687: NIFI-2298 added Kafka consume attributes to a FlowFile

Posted by joewitt <gi...@git.apache.org>.
Github user joewitt commented on the issue:

    https://github.com/apache/nifi/pull/687
  
    There are definitely ways to defeat backpressure from working properly when implementing processors though so definitely a fair question for something like this.


---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---

[GitHub] nifi issue #687: NIFI-2298 added Kafka consume attributes to a FlowFile

Posted by xmlking <gi...@git.apache.org>.
Github user xmlking commented on the issue:

    https://github.com/apache/nifi/pull/687
  
    Yes. Thanks 
    
    Sent from my iPhone
    
    > On Jul 21, 2016, at 5:09 PM, Oleg Zhurakousky <no...@github.com> wrote:
    > 
    > @xmlking Back Pressure is the function of all processors so there is nothing specific required in ConsumeKafka to handle it. Does that answer your question?
    > 
    > \u2014
    > You are receiving this because you were mentioned.
    > Reply to this email directly, view it on GitHub, or mute the thread.
    > 



---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---