Mark Payne created NIFI-3182:
--------------------------------

             Summary: 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
            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)

Reply via email to