Ошибка подключения к базе данных при чтении из копии - PullRequest
Новая
       38

Ошибка подключения к базе данных при чтении из копии

0 голосов
/ 03 марта 2020

Я использую разъем источника kafka для записи CD C от RDS Aurora Postgres. Получаю эту ошибку. Пожалуйста, помогите, если кто-то знает эту проблему. 

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

Ответы [ 2 ]

0 голосов
/ 16 марта 2020

да Иржи Печане c. На самом деле проблема была с версией debezium. Старая версия не поддерживает функцию автоматического подключения Postgres, если соединение потеряно из-за какой-то временной проблемы Теперь новая версия debezium (1.1.0) поддерживает функцию автоматического подключения.

0 голосов
/ 16 марта 2020

Debezium 1.1.0.CR1 уже выполняет автоматическое переподключение в этих случаях https://debezium.io/blog/2020/03/13/debezium-1-1-c1-released/

...