DBZ-1081 JavaDoc; adding Addison Higham to COPYRIGHT.txt

COPYRIGHT.txt

@@ -1,4 +1,5 @@
 Aaron Rosenberg
+Addison Higham
 Akshath Patkar
 Amit Sela
 Andreas Bergmeier

debezium-connector-postgres/src/main/java/io/debezium/connector/postgresql/connection/PostgresConnection.java

@@ -170,6 +170,10 @@ protected ServerInfo.ReplicationSlot queryForSlot(String slotName, String databa
         }, map);
     }
 
+    /**
+     * Obtains the LSN to resume streaming from. On PG 9.5 there is no confirmed_flushed_lsn yet, so restart_lsn will be
+     * read instead. This may result in more records to be re-read after a restart.
+     */
     private Long parseConfirmedFlushLsn(String slotName, String pluginName, String database, ResultSet rs) {
         Long confirmedFlushedLsn = null;
 
@@ -182,7 +186,7 @@ private Long parseConfirmedFlushLsn(String slotName, String pluginName, String d
                 confirmedFlushedLsn = tryParseLsn(slotName, pluginName, database, rs, "restart_lsn");
             }
             catch (SQLException e2) {
-                throw new ConnectException("Neither confirmed_flush_lsn or restart_lsn could be found");
+                throw new ConnectException("Neither confirmed_flush_lsn nor restart_lsn could be found");
             }
         }