How to solve Error 'KafkaJSONParser() does not exist, or permission is denied for KafkaJSONParse'
Hi,
we use the KafkaJSONParser in a COPY query using KafkaSource and we get the following error:
[42883] ERROR: Function KafkaJSONParser() does not exist, or permission is denied for KafkaJSONParser()
How to I grant permissions to the user to the KafkaJSONParser?
I tried, similarly to KafkaSource, but the did not work. However, I granted permissons to kafkalib and KafkaSource:
GRANT USAGE ON library kafkalib to <user>; GRANT EXECUTE ON source KafkaSource() to <user>;
0
Answers
Hi,
this behavior could occur if you overwrite the "search_path" in your session definition or user profile
https://www.vertica.com/docs/12.0.x/HTML/Content/Authoring/AdministratorsGuide/ConfiguringTheDB/SettingSchemaSearchPaths.htm
Try : SHOW SEARCH_PATH;
and see if you have the "public" schema still in the search path
If no, it should be your problem
If yes (public in the search_path), we have another problem
Regards
We needed
GRANT EXECUTE ON parser KafkaJSONParser() to <user>;
That fixed the problem. Before we had missed the 'parser'-keyword in the query.