Our Community is getting an upgrade! To get everything ready for the relaunch, we’ll be placing the site in read-only mode starting September 21st.
We really appreciate your understanding while we get things set up behind the scenes. Catch up on all the exciting details about the move here.
Need help or have questions? Drop us a line at [email protected]
Created 04-03-2025 05:58 PM
Hi community,
Our NIFI version: 1.23.0.
We are converting JSON message to AVRO format and posting to KAFKA topic using
JSON Tree Reader:
AVRO Record Set Writer:
Confluent Schema Registry:
We are not able to post the message with the error below.
We are able to see the AVRO schema in the KAFKA registry through POSTMAN and using browser URL and we are able to connect to that KAFKA topic with the same parameters in NIFI .
Could you please help us to resolve this issue.
Error:
Created 04-04-2025 10:18 AM
@MariaE
It sounds like from the shared exception the data coming from your source json did not match the schema returned from "zv60-u-ab-...". Looks like the data had a null value in the channel field but the schema does not support null values.
So either an issue with the source data or the schema needs to be modified to support null values.
Please help our community grow. If you found any of the suggestions/solutions provided helped you with solving your issue or answering your question, please take a moment to login and click "Accept as Solution" on one or more of them that helped.
Thank you,
Matt
Created 04-04-2025 10:18 AM
@MariaE
It sounds like from the shared exception the data coming from your source json did not match the schema returned from "zv60-u-ab-...". Looks like the data had a null value in the channel field but the schema does not support null values.
So either an issue with the source data or the schema needs to be modified to support null values.
Please help our community grow. If you found any of the suggestions/solutions provided helped you with solving your issue or answering your question, please take a moment to login and click "Accept as Solution" on one or more of them that helped.
Thank you,
Matt
Created 04-04-2025 12:51 PM
Hi Matt,
yes it was the case of null values - we updated avro schema and set default values for enums and were able to connect and post messages to kafka.
Thanks