When I I am trying to retrieve data from a MSSQL database , Logstash JDBC input not connecting to the required custom port 59237. Logstash only trying to connect port 3306.
Mentioned the required port 59237 in Connection string. But Logstash still sending request to port 3306 ( Same Port mentioned in logstash documentaion )
DB and Logstash in Same Timezone
Firewall log checked and confirmed that my logstash is trying to connect 3306.
My connection String is
**jdbc_connection_string => "jdbc:mysql://DB_Ip:59237/SQLPROD"**
Conf:
input {
jdbc {
jdbc_driver_library => "/home/ubuntu/logstash-8.5.3/lib/jar/mysql-connector-java-5.1.36-bin.jar"
jdbc_driver_class => "com.mysql.jdbc.Driver"
jdbc_connection_string => "jdbc:mysql://DB_Ip:59237/SQLPROD"
jdbc_user => "username"
jdbc_password => "password"
schedule => "* * * * *"
statement => "select * from vlog"
jdbc_validate_connection => "true"
}
}
Error message
[2023-06-22T11:34:00,108][ERROR][logstash.inputs.jdbc ][main][20e72f1a873bfa286818f8df6e6a163bfa90d2a7439484838b895d09e47b1e05] Unable to connect to database. Tried 1 times {:message=>"Java::ComMysqlJdbcExceptionsJdbc4::CommunicationsException: Communications link failure\n\nThe last packet sent successfully to the server was 0 milliseconds ago. The driver has not received any packets from the server.", :exception=>Sequel::DatabaseConnectionError, :cause=>#<Java::ComMysqlJdbcExceptionsJdbc4::CommunicationsException: Communications link failure
The last packet sent successfully to the server was 0 milliseconds ago. The driver has not received any packets from the server.>, :backtrace=>["jdk.internal.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)", "jdk.internal.reflect.NativeConstructorAccessorImpl.newInstance(jdk/internal/reflect/NativeConstructorAccessorImpl.java:77)", "jdk.internal.reflect.DelegatingConstructorAccessorImpl.newInstance(jdk/internal/reflect/DelegatingConstructorAccessorImpl.java:45)", "java.lang.reflect.Constructor.newInstanceWithCaller(java/lang/reflect/Constructor.java:499)", "java.lang.reflect.Constructor.newInstance(java/lang/reflect/Constructor.java:480)",