Uploaded image for project: 'Debezium'
  1. Debezium
  2. DBZ-5031

Debezium has never found starting LSN

XMLWordPrintable

    • False
    • None
    • False
    • Hide

      We can't

      Show
      We can't

      Hello, 

      Debezium after a reboot, during the process of looking for a starting position in WAL never found it. 

      It kept throwing up logs for 10 hours:

      'INFO Postgres|postgres-connector-task Streaming requested from LSN LSN{2AEAF/E2245128}, received LSN LSN{2AF65/B84E7808} identified as already processed [io.debezium.connector.postgresql.connection.AbstractMessageDecoder]'

      while simultaneously committing progress, which ends up cleaning up WAL. Unfortunately, we lost a lot of data because the searching process did not break with any exception.

       

      It looks as if the condition in WalPositionLocator has never been met: 
              if (startStreamingLsn == null || startStreamingLsn.equals(lsn))

       

      We also observed that the offsets commited to kafka at restart time were not increasing. E.g. 98 - 100 - 99 - 101 

      Unfortunately the logs were lost after restarting the container (restart also solved the problem)

       

      We are using debezium 1.5 with on-premise postgres (with huge load and hundreds of tables, complicated procedures and so on) 14 with logical replication (pgout)

       

      Do you have any idea what happened and how to prevent it in the future?

              Unassigned Unassigned
              vallerboy Oskar Polak (Inactive)
              Votes:
              1 Vote for this issue
              Watchers:
              9 Start watching this issue

                Created:
                Updated:
                Resolved: