[ https://issues.apache.org/jira/browse/NIFI-8785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17390788#comment-17390788 ]
ASF subversion and git services commented on NIFI-8785: ------------------------------------------------------- Commit 5117fc0619a5f618100f210474ed3aff3a58c60a in nifi's branch refs/heads/main from Pierre Villard [ https://gitbox.apache.org/repos/asf?p=nifi.git;h=5117fc0 ] NIFI-8785 Confluent Schema Registry REST client refactoring - Added debug logs and a new method to get schema info without making subjects API calls This closes #5250 Signed-off-by: David Handermann <exceptionfact...@apache.org> > 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 > Assignee: Pierre Villard > Priority: Major > Attachments: Kafka_Confluent_Schema_Suffering.json, nifi-app.rar > > Time Spent: 40m > Remaining Estimate: 0h > > 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)