Topic Messages: connect-cluster-status

Partition: 3   Offset: 9   Key: status-topic-health.public.HealthCheckResults:connector-debezium-ocean-scraping-health-check   Timestamp: 2026-05-04 04:05:13.899 Headers: empty
  
empty
Partition: 0   Offset: 9   Key: status-task-debezium-ocean-scraping-health-check-0   Timestamp: 2026-05-04 04:05:13.905 Headers: empty
  
empty
Partition: 3   Offset: 10   Key: status-connector-debezium-ocean-scraping-health-check   Timestamp: 2026-05-04 04:05:13.905 Headers: empty
  
empty
Partition: 2   Offset: 3   Key: status-connector-debezium-ocean-mastertracking   Timestamp: 2026-05-04 04:25:56.016 Headers: empty
  
{"state":"RUNNING","trace":null,"worker_id":"10.1.4.123:8083","generation":16}
Partition: 3   Offset: 18   Key: status-task-debezium-ocean-mastertracking-0   Timestamp: 2026-05-04 04:25:56.315 Headers: empty
  
{"state":"RUNNING","trace":null,"worker_id":"10.1.4.123:8083","generation":17}
Partition: 3   Offset: 19   Key: status-connector-debezium-ocean-scrappingtrackings   Timestamp: 2026-05-04 04:26:03.083 Headers: empty
  
{"state":"RUNNING","trace":null,"worker_id":"10.1.4.123:8083","generation":18}
Partition: 3   Offset: 20   Key: status-task-debezium-ocean-scrappingtrackings-0   Timestamp: 2026-05-04 04:26:03.224 Headers: empty
  
{"state":"RUNNING","trace":null,"worker_id":"10.1.4.123:8083","generation":19}
Partition: 0   Offset: 14   Key: status-topic-events.public.UserTrackings:connector-debezium-ocean-scrappingtrackings   Timestamp: 2026-05-04 04:26:04.431 Headers: empty
  
{"topic":{"name":"events.public.UserTrackings","connector":"debezium-ocean-scrappingtrackings","task":0,"discoverTimestamp":1777868764430}}
Partition: 0   Offset: 15   Key: status-topic-event.public.container_bl_details:connector-debezium-ocean-mastertracking   Timestamp: 2026-05-04 04:27:21.156 Headers: empty
  
{"topic":{"name":"event.public.container_bl_details","connector":"debezium-ocean-mastertracking","task":0,"discoverTimestamp":1777868841156}}
Partition: 3   Offset: 21   Key: status-task-debezium-ocean-mastertracking-0   Timestamp: 2026-06-05 08:46:47.818 Headers: empty
  
{"state":"FAILED","trace":"io.debezium.DebeziumException: Couldn't obtain encoding for database oceantrackingprod\n\tat io.debezium.connector.postgresql.connection.PostgresConnection.getDatabaseCharset(PostgresConnection.java:574)\n\tat io.debezium.connector.postgresql.PostgresConnectorTask.start(PostgresConnectorTask.java:82)\n\tat io.debezium.connector.common.BaseSourceTask.startIfNeededAndPossible(BaseSourceTask.java:249)\n\tat io.debezium.connector.common.BaseSourceTask.poll(BaseSourceTask.java:169)\n\tat org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.poll(AbstractWorkerSourceTask.java:457)\n\tat org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.execute(AbstractWorkerSourceTask.java:351)\n\tat org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:202)\n\tat org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:257)\n\tat org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.run(AbstractWorkerSourceTask.java:75)\n\tat org.apache.kafka.connect.runtime.isolation.Plugins.lambda$withClassLoader$1(Plugins.java:177)\n\tat java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)\n\tat java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)\n\tat java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)\n\tat java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)\n\tat java.base/java.lang.Thread.run(Thread.java:833)\nCaused by: org.postgresql.util.PSQLException: Connection to intemo-prod-db.cn7xvgq4xmpi.ap-south-1.rds.amazonaws.com:5432 refused. Check that the hostname and port are correct and that the postmaster is accepting TCP/IP connections.\n\tat org.postgresql.core.v3.ConnectionFactoryImpl.openConnectionImpl(ConnectionFactoryImpl.java:319)\n\tat org.postgresql.core.ConnectionFactory.openConnection(ConnectionFactory.java:49)\n\tat org.postgresql.jdbc.PgConnection.<init>(PgConnection.java:247)\n\tat org.postgresql.Driver.makeConnection(Driver.java:434)\n\tat org.postgresql.Driver.connect(Driver.java:291)\n\tat io.debezium.jdbc.JdbcConnection.lambda$patternBasedFactory$1(JdbcConnection.java:241)\n\tat io.debezium.jdbc.JdbcConnection$ConnectionFactoryDecorator.connect(JdbcConnection.java:127)\n\tat io.debezium.jdbc.JdbcConnection.connection(JdbcConnection.java:873)\n\tat io.debezium.jdbc.JdbcConnection.connection(JdbcConnection.java:868)\n\tat io.debezium.connector.postgresql.connection.PostgresConnection.getDatabaseCharset(PostgresConnection.java:571)\n\t... 14 more\nCaused by: java.net.ConnectException: Connection refused\n\tat java.base/sun.nio.ch.Net.pollConnect(Native Method)\n\tat java.base/sun.nio.ch.Net.pollConnectNow(Net.java:672)\n\tat java.base/sun.nio.ch.NioSocketImpl.timedFinishConnect(NioSocketImpl.java:549)\n\tat java.base/sun.nio.ch.NioSocketImpl.connect(NioSocketImpl.java:597)\n\tat java.base/java.net.SocksSocketImpl.connect(SocksSocketImpl.java:327)\n\tat java.base/java.net.Socket.connect(Socket.java:633)\n\tat org.postgresql.core.PGStream.createSocket(PGStream.java:241)\n\tat org.postgresql.core.PGStream.<init>(PGStream.java:98)\n\tat org.postgresql.core.v3.ConnectionFactoryImpl.tryConnect(ConnectionFactoryImpl.java:109)\n\tat org.postgresql.core.v3.ConnectionFactoryImpl.openConnectionImpl(ConnectionFactoryImpl.java:235)\n\t... 23 more\n","worker_id":"10.1.4.123:8083","generation":19}
Partition: 2   Offset: 4   Key: status-connector-debezium-ocean-mastertracking   Timestamp: 2026-06-06 05:41:13.258 Headers: empty
  
{"state":"UNASSIGNED","trace":null,"worker_id":"10.1.4.123:8083","generation":19}
Partition: 0   Offset: 16   Key: status-topic-event.public.container_bl_details:connector-debezium-ocean-mastertracking   Timestamp: 2026-06-06 05:41:13.304 Headers: empty
  
empty
Partition: 0   Offset: 17   Key: status-topic-event.public.container_bl_details:connector-debezium-ocean-mastertracking   Timestamp: 2026-06-06 05:41:13.305 Headers: empty
  
empty
Partition: 2   Offset: 5   Key: status-connector-debezium-ocean-mastertracking   Timestamp: 2026-06-06 05:41:13.319 Headers: empty
  
empty
Partition: 3   Offset: 22   Key: status-task-debezium-ocean-mastertracking-0   Timestamp: 2026-06-06 05:41:13.319 Headers: empty
  
empty
Partition: 3   Offset: 23   Key: status-task-debezium-ocean-mastertracking-0   Timestamp: 2026-06-06 05:41:13.319 Headers: empty
  
empty
Partition: 2   Offset: 6   Key: status-connector-debezium-ocean-mastertracking   Timestamp: 2026-06-06 05:42:55.162 Headers: empty
  
{"state":"RUNNING","trace":null,"worker_id":"10.1.4.123:8083","generation":22}
Partition: 3   Offset: 24   Key: status-task-debezium-ocean-mastertracking-0   Timestamp: 2026-06-06 05:42:55.323 Headers: empty
  
{"state":"RUNNING","trace":null,"worker_id":"10.1.4.123:8083","generation":23}
Partition: 0   Offset: 18   Key: status-topic-event.public.container_bl_details:connector-debezium-ocean-mastertracking   Timestamp: 2026-06-06 05:42:56.519 Headers: empty
  
{"topic":{"name":"event.public.container_bl_details","connector":"debezium-ocean-mastertracking","task":0,"discoverTimestamp":1780724576519}}