[ 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)