IBM Event Streams and IBM Event Automation

 View Only
Expand all | Collapse all

Postgresql connector configuration in Event streams 10.4.0

  • 1.  Postgresql connector configuration in Event streams 10.4.0

    Posted Wed June 22, 2022 02:53 AM
    Hi,

    I have configured postgresql debezium source connector in event streams(instance running on CP4I). Then tested the connection for postgresql and it is successful. But I am getting below error after starting the connector.

    Error details:
    ..............................................
    "Message: PUT /connectors/pgsql-demo/config returned 500 (Internal Server Error): IO Error trying to forward REST request: java.net.SocketTimeoutException: Connect Timeout
    Reason: ConnectRestException"

    2022-06-22 06:46:58,321 ERROR IO error forwarding REST request: (org.apache.kafka.connect.runtime.rest.RestClient)  java.util.concurrent.ExecutionException: java.net.SocketTimeoutException: Connect Timeout at org.eclipse.jetty.client.util.FutureResponseListener.getResult(FutureResponseListener.java:118) at org.eclipse.jetty.client.util.FutureResponseListener.get(FutureResponseListener.java:101) at org.eclipse.jetty.client.HttpRequest.send(HttpRequest.java:730)
    ...............................................

    Please guide me on above error to fix it.

    Thanks
    Bhanu Prakash


    ------------------------------
    Bhanu Prakash Desakuru
    ------------------------------


  • 2.  RE: Postgresql connector configuration in Event streams 10.4.0
    Best Answer

    Posted Thu July 07, 2022 02:27 PM
    Hi Bhanu,

    Here's a suggestion from one of our IBM experts:

    A connection time out may be due to kafka brokers; so you will need to set the cluster connect configuration with good user and authentication method: tls or sram.
    Here is an example for the kafka connector clsuter https://github.com/ibm-cloud-architecture/eda-rt-inventory-gitops/blob/main/environments/rt-inventory-dev/services/kconnect/kafka-connect.yaml here is an example of postgresql with debezium      https://github.com/ibm-cloud-architecture/eda-saga-orchestration/blob/main/bootstrap/register-order-connector.json


    Hope that helps!

    ------------------------------
    Jina K
    ------------------------------

    Original Message