nifi-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF subversion and git services (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (NIFI-1629) Downgrade Kafka processors back to 0.8
Date Wed, 16 Mar 2016 19:39:33 GMT

    [ https://issues.apache.org/jira/browse/NIFI-1629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15198001#comment-15198001
] 

ASF subversion and git services commented on NIFI-1629:
-------------------------------------------------------

Commit 148b4497b4a31f292e9b5b2fba3ee19555bf808b in nifi's branch refs/heads/master from [~ozhurakousky]
[ https://git-wip-us.apache.org/repos/asf?p=nifi.git;h=148b449 ]

NIFI-1629 This closes #282. downgraded Kafka back to 0.8 - added context.yield to PutKafka
- added lifecycle hooks to defend from Kafka deadlocks

NIFI-1629 changd thread pool implementation in Get/PutKafka

Signed-off-by: joewitt <joewitt@apache.org>


> Downgrade Kafka processors back to 0.8
> --------------------------------------
>
>                 Key: NIFI-1629
>                 URL: https://issues.apache.org/jira/browse/NIFI-1629
>             Project: Apache NiFi
>          Issue Type: Bug
>            Reporter: Oleg Zhurakousky
>            Assignee: Oleg Zhurakousky
>             Fix For: 0.6.0
>
>
> Also, the following needs to be added to ensure that Kafka failures do not affect NiFi
operations
> 1) Add yield so when we don't have to ack anything or there is nothing to send we don't
do onTrigger()
> 2) Appropriate hooks allowing Kafka processors to still exit whenever Kafka deadlocks



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Mime
View raw message