Fully qualified table names in the Postgres JDBC Sink #23812
Unanswered
conor-nsurely
asked this question in
Q&A
Replies: 0 comments
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Uh oh!
There was an error while loading. Please reload this page.
The sink is connecting to the DB via pgBouncer, which seems to break passing the search path in the URL eg currentSchema=myschema
I've tried passing the fully qualified table name in the sink's "tableName" config parameter, but this just produces an error saying the table is not found.
I cannot set the default search parameter for the user either for my use case.
Is there no way to pass myschema.mytable or am I missing something?
I am using pulsar 4.0.1
Thanks!
All reactions