How to solve Error 'KafkaJSONParser() does not exist, or permission is denied for KafkaJSONParse'

joergschaber

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>;

Francois

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

joergschaber

We needed
GRANT EXECUTE ON parser KafkaJSONParser() to <user>;

That fixed the problem. Before we had missed the 'parser'-keyword in the query.