[
https://issues.apache.org/jira/browse/NIFI-8785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17382074#comment-17382074
]
Pierre Villard commented on NIFI-8785:
--------------------------------------
I tried with your flow definition and it's working properly on my side. How are
you generating your messages?
On my side, I'm publishing the messages in Kafka using GenerateFlowFile
processors (each one for messages with different schemas) and
PublishKafkaRecord processor where the writer is encoding the schema reference
in the message.
> AvroReader controller can't get confluent schema IDs except only the latest
> ---------------------------------------------------------------------------
>
> Key: NIFI-8785
> URL: https://issues.apache.org/jira/browse/NIFI-8785
> Project: Apache NiFi
> Issue Type: Bug
> Components: Extensions
> Affects Versions: 1.12.1
> Environment: CentOS7
> Reporter: Arsen Tavitov
> Priority: Major
> Attachments: Kafka_Confluent_Schema_Suffering.json, nifi-app.rar
>
>
> While trying to read Confluent Schema Registry Avro files(from Kafka) with
> different schema IDs with AvroReader controller error "could not get Schema
> with id: <schema id>" appears.
> NiFi version: 1.12.1
> Confluent Schema Registry version: 5.5.2
> Using the following test flow in Nifi
> ConsumeKafka_2_6 1.12.1 ---> ConvertRecord 1.12.1
> In ConvertRecord processor we are using AvroReader controller as record
> reader.
> AvroReader controller properties:
> * schema access strategy: confluent content-encoded schema reference
> * schema registry: Confluent Schema Registry controller
> * schema name: ${schema.name} (default value)
> * schema version: no value set
> * schema branch: no value set
> * schema text: ${schema.text} (default value)
> * cash size: 1000 (default value)
> Similar issue:
> [https://community.cloudera.com/t5/Support-Questions/Nifi-ConsumeKafakRecord-0-11-Throws-Error-quot-Could-not/td-p/185636]
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
