title: Database connection failed when reading from copy
body: <p>I am using kafka source connector for capturing CDC from RDS Aurora Postgres. Getting this error.
  Please assist if someone know this issue.</p>
  
  <pre><code>Caused by: org.postgresql.util.PSQLException: Database connection failed when reading from copy
      at org.postgresql.core.v3.QueryExecutorImpl.readFromCopy(QueryExecutorImpl.java:1074)
      at org.postgresql.core.v3.CopyDualImpl.readFromCopy(CopyDualImpl.java:37)
      at org.postgresql.core.v3.replication.V3PGReplicationStream.receiveNextData(V3PGReplicationStream.java:158)
      at org.postgresql.core.v3.replication.V3PGReplicationStream.readInternal(V3PGReplicationStream.java:123)
      at org.postgresql.core.v3.replication.V3PGReplicationStream.readPending(V3PGReplicationStream.java:80)
      at io.debezium.connector.postgresql.connection.PostgresReplicationConnection$1.readPending(PostgresReplicationConnection.java:397)
      at io.debezium.connector.postgresql.PostgresStreamingChangeEventSource.execute(PostgresStreamingChangeEventSource.java:119)
      at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:99)
      ... 5 more 
  Caused by: java.net.SocketException: Socket is closed
      at java.base/java.net.Socket.setSoTimeout(Socket.java:1155)
      at java.base/sun.security.ssl.BaseSSLSocketImpl.setSoTimeout(BaseSSLSocketImpl.java:639)
      at java.base/sun.security.ssl.SSLSocketImpl.setSoTimeout(SSLSocketImpl.java:73)
      at org.postgresql.core.PGStream.setNetworkTimeout(PGStream.java:589)
      at org.postgresql.core.PGStream.hasMessagePending(PGStream.java:139)
      at org.postgresql.core.v3.QueryExecutorImpl.processCopyResults(QueryExecutorImpl.java:1109)
      at org.postgresql.core.v3.QueryExecutorImpl.readFromCopy(QueryExecutorImpl.java:1072)
      ... 12 more
  </code></pre>