You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@nifi.apache.org by "Mark Payne (JIRA)" <ji...@apache.org> on 2016/12/09 22:12:58 UTC

[jira] [Commented] (NIFI-3182) PublishKafka and PublishKafka_0_10 hang indefinitely, continually sending the same message, if delimiter ends at 8 KB mark

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

Mark Payne commented on NIFI-3182:
----------------------------------

This appears to have been addressed already in version 1.1.0, as this processor was heavily refactored for NIFI-2865.

> PublishKafka and PublishKafka_0_10 hang indefinitely, continually sending the same message, if delimiter ends at 8 KB mark
> --------------------------------------------------------------------------------------------------------------------------
>
>                 Key: NIFI-3182
>                 URL: https://issues.apache.org/jira/browse/NIFI-3182
>             Project: Apache NiFi
>          Issue Type: Bug
>          Components: Extensions
>    Affects Versions: 1.0.0
>            Reporter: Mark Payne
>
> If PublishKafka is configured to send using a delimiter, and it receives a FlowFile whose content contains the delimiter, and that delimiter ends at the 8 KB mark (8192 bytes into the FlowFile Content), then PublishKafka will get stuck in an infinite loop, sending the same message over and over.
> To replicate, create a simple Flow:
> GenerateFlowFile -> ReplaceText -> PublishKafka
> For GenerateFlowFile, generate a message that is 8187 bytes.
> With ReplaceText, configure it to always append the value "HELLO" (without quotes).
> Configure PublishKafka to use a demarcator of "HELLO" (without quotes).
> When PublishKafka attempts to send the data, it will continually send the randomly generated data over and over and over, never relinquishing its thread.



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