[
https://issues.apache.org/jira/browse/NIFI-8539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nikolay Nikolaev updated NIFI-8539:
-----------------------------------
Description:
Steps to reproduce the bug:
* build a simple flow: read data from Kafka with "ConsumeKafkaRecord_2_0
1.13.0" and write output file with PutFile ( !test_flow.png! )
* Periodically, some flowfiles get incorrect. Example: [^data in Kafka.json]
contains "raw"-data from kafka topic, and
[^38f1d0f9-33c9-4cf1-978a-9060274615a5.avro] is output flowfile.
We can see, that section "after" is different in this files, even though it
should be the same record
In Kafka - !see in Avro.PNG!
In Flowfile - !see in Avro.PNG!
The error does not always appear, but only in some records.
was:
Steps to reproduce the bug:
* build a simple flow: read data from Kafka with "ConsumeKafkaRecord_2_0
1.13.0" and write output file with PutFile (see picture)
* Periodically, some flowfiles get incorrect. Example: file contains "raw"-data
from kafka topic, and file is output flowfile (and
> ConsumeKafkaRecord_2_0 1.13.0:
> -------------------------------
>
> Key: NIFI-8539
> URL: https://issues.apache.org/jira/browse/NIFI-8539
> Project: Apache NiFi
> Issue Type: Bug
> Components: Core Framework
> Affects Versions: 1.13.0
> Reporter: Nikolay Nikolaev
> Priority: Major
> Attachments: 38f1d0f9-33c9-4cf1-978a-9060274615a5.avro, data in
> Kafka.json, see in Avro.PNG, see in Kafka.PNG, test_flow.png
>
>
> Steps to reproduce the bug:
> * build a simple flow: read data from Kafka with "ConsumeKafkaRecord_2_0
> 1.13.0" and write output file with PutFile ( !test_flow.png! )
> * Periodically, some flowfiles get incorrect. Example: [^data in Kafka.json]
> contains "raw"-data from kafka topic, and
> [^38f1d0f9-33c9-4cf1-978a-9060274615a5.avro] is output flowfile.
> We can see, that section "after" is different in this files, even though it
> should be the same record
> In Kafka - !see in Avro.PNG!
> In Flowfile - !see in Avro.PNG!
> The error does not always appear, but only in some records.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
