Unlock a world of possibilities! Login now and discover the exclusive benefits awaiting you.
Hi Team we are facing issue in CDC from Aurora postgres source.
As we have fulfilled all the prerequisites we are getting unable to create replication slot.
Attaching the error message below:
Creating replication slot 'postgres_source__00016415_78935867_4089_e74e_8879_d6f91df326e4' failed.
wal_slot_create(...) - Unable to create slot 'postgres_source__00016415_78935867_4089_e74e_8879_d6f91df326e4' (on execute(...) phase)
RetCode: SQL_ERROR SqlState: 57014 NativeError: 1 Message: ERROR: canceling statement due to statement timeout;
Error while executing the query
Failed (retcode -1) to execute statement: 'SELECT lsn FROM pg_create_logical_replication_slot('postgres_source__00016415_78935867_4089_e74e_8879_d6f91df326e4', 'test_decoding')'
Please help us to resolve this issue.
Regards,
Sushant
Hello @sush_1 ,
Thanks for the update. So far Replicate works fine now, right?
Replicate will detect the slot automatically, if the slot does not exist Replicate will create it and then use the slot. Or you may use an internal parameter slotName to specify the given slot.
Regards,
John.
Hello @sush_1 ,
Thanks for opening the article.
In general the create slot operation should be done quikcly, if it's a pure timeout issue then you may add an internal parameter in the endpoint and set its value to a reasonable value (default is 60 seconds) as below:
Or you may try to create a slot manually to trace the error, a sample :
SELECT xlog_position FROM pg_create_logical_replication_slot('postgres_source__00016415_78935867_4089_e74e_8879_d6f91df326e4', 'test_decoding')
Hope this helps.
Regards,
John.
Hi John,
We added above mentioned internal parameter. and also ran the query to create slot manually. It saying that the slot is already exists.
Regards,
Sushant
Hello @sush_1 ,
Thanks for the update. So far Replicate works fine now, right?
Replicate will detect the slot automatically, if the slot does not exist Replicate will create it and then use the slot. Or you may use an internal parameter slotName to specify the given slot.
Regards,
John.