Dmytro Vorotyntsev
08/19/2022, 8:20 AMPSQLException: ERROR: publication "airbyte_publication" does not exist Which doesn’t seem correct since few logs line above it was clear that Airbyte worker got a list of tables which are added to mentioned publication. Details in thread.Dmytro Vorotyntsev
08/19/2022, 8:27 AM2022-08-19 08:29:27 source > 2022-08-19 08:29:27 INFO i.d.p.ChangeEventSourceCoordinator(streamEvents):173 - Starting streaming
2022-08-19 08:29:27 source > 2022-08-19 08:29:27 INFO i.d.c.p.PostgresStreamingChangeEventSource(execute):127 - Retrieved latest position from stored offset 'null'
2022-08-19 08:29:27 source > 2022-08-19 08:29:27 INFO i.d.c.p.c.WalPositionLocator(<init>):40 - Looking for WAL restart position for last commit LSN 'null' and last change LSN 'null'
2022-08-19 08:29:27 source > 2022-08-19 08:29:27 INFO i.d.c.p.c.PostgresReplicationConnection(initPublication):145 - Initializing PgOutput logical decoder publication
2022-08-19 08:29:27 source > 2022-08-19 08:29:27 INFO i.d.c.p.c.PostgresConnection(readReplicationSlotInfo):251 - Obtained valid replication slot ReplicationSlot [active=false, latestFlushedLsn=LSN{0/407E708}, catalogXmin=1932731695]
2022-08-19 08:29:27 source > 2022-08-19 08:29:27 INFO i.d.j.JdbcConnection(lambda$doClose$3):956 - Connection gracefully closed
2022-08-19 08:29:27 source > 2022-08-19 08:29:27 INFO i.d.u.Threads(threadFactory):270 - Requested thread factory for connector PostgresConnector, id = backend named = keep-alive
2022-08-19 08:29:27 source > 2022-08-19 08:29:27 INFO i.d.u.Threads$3(newThread):287 - Creating thread debezium-postgresconnector-backend-keep-alive
2022-08-19 08:29:27 source > 2022-08-19 08:29:27 INFO i.d.c.p.PostgresSchema(printReplicaIdentityInfo):103 - REPLICA IDENTITY for 'public.users' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns
2022-08-19 08:29:27 source > 2022-08-19 08:29:27 INFO i.d.c.p.PostgresSchema(printReplicaIdentityInfo):103 - REPLICA IDENTITY for 'public.devices' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns
2022-08-19 08:29:27 source > 2022-08-19 08:29:27 INFO i.d.c.p.PostgresStreamingChangeEventSource(processMessages):202 - Processing messages
2022-08-19 08:29:27 source > 2022-08-19 08:29:27 ERROR i.d.p.ErrorHandler(setProducerThrowable):35 - Producer failure
2022-08-19 08:29:27 source > org.postgresql.util.PSQLException: ERROR: publication "airbyte_publication" does not exist
2022-08-19 08:29:27 source > Where: slot "airbyte_slot", output plugin "pgoutput", in the change callback, associated LSN 0/407E708
2022-08-19 08:29:27 source > at org.postgresql.core.v3.QueryExecutorImpl.receiveErrorResponse(QueryExecutorImpl.java:2675) ~[postgresql-42.3.5.jar:42.3.5]
2022-08-19 08:29:27 source > at org.postgresql.core.v3.QueryExecutorImpl.processCopyResults(QueryExecutorImpl.java:1263) ~[postgresql-42.3.5.jar:42.3.5]
...Dmytro Vorotyntsev
08/19/2022, 8:28 AMDmytro Vorotyntsev
08/19/2022, 8:37 AMDmytro Vorotyntsev
08/19/2022, 8:54 AMDmytro Vorotyntsev
08/19/2022, 8:54 AMAdam Bloom
08/19/2022, 3:58 PMDmytro Vorotyntsev
08/19/2022, 7:55 PM