Re: [debezium] Request timed out

[Chris Cranford]

Hi,

It would appear that your CURL request timed out per the "message" in the 500 response and then seeing that the log entries in Kafka Connect have a nearly 90 second+ delay.  This doesn't look related to Debezium but rather something that has your Kafka Connect environment potentially unstable. Do you see any other WARN/ERROR messages in the well before the connector restart?

Chris

On 3/20/24 04:15, 추거누 wrote:

I got timed out message... 

Weirdly, i can connect mysql database.

but, i don't know why timed out message occurred.

------------------------- timeout message

[root@localhost kafka]# curl -i -X POST -H "Accept:application/json" \
> -H "Content-Type:application/json" http://192.168.56.120:8083/connectors/ \
> -d '{
>           "name": "mysql-debezium",
>           "config": {
>                "connector.class": "io.debezium.connector.mysql.MySqlConnector",
>                "tasks.max": "3",
>                "database.hostname": "192.168.56.115",
>                "database.port": "3306",
>                "database.user": "dbzuser",
>                "database.password": "123456789",
>                "database.server.id": "184054",
>                "database.serverTimezone": "Asia/Seoul",
>                "topic.prefix" : "target",
>                "schema.history.internal.kafka.bootstrap.servers": "192.168.56.117:9092,192.168.56.118:9092,192.168.56.119:9092",
>                "schema.history.internal.kafka.topic": "mysql.schema-changes.inventory",
>                "include.schema.changes": "true",
>                "transforms": "reroute, unwrap",
>                "transforms.unwrap.type":"io.debezium.transforms.ExtractNewRecordState",
>                "transforms.unwrap.drop.tombstones":false,
>                "transforms.unwrap.delete.handling.mode":"rewrite",
>                "transforms.unwrap.add.fields":"op",
>                "transforms.reroute.type":"io.debezium.transforms.ByLogicalTableRouter",
>                "transforms.reroute.topic.regex":"(.*).(.*).(.*)",
>                "transforms.reroute.topic.replacement":"$1.public.mysql_$3"
>           }
>      }'
HTTP/1.1 100 Continue

HTTP/1.1 500 Internal Server Error
Date: Wed, 20 Mar 2024 08:05:42 GMT
Content-Type: application/json
Content-Length: 48
Server: Jetty(9.4.52.v20230823)

{"error_code":500,"message":"Request timed out"}[root@localhost kafka]# 

----------------------- kafka connect log

[2024-03-20 17:05:42,288] INFO [mysql-debezium|worker] Instantiated connector mysql-debezium with version 2.5.2.Final of type class io.debezium.connector.mysql.MySqlConnector (org.apache.kafka.connect.runtime.Worker:330)
[2024-03-20 17:05:42,302] INFO [mysql-debezium|worker] Finished creating connector mysql-debezium (org.apache.kafka.connect.runtime.Worker:351)
[2024-03-20 17:05:42,309] INFO SourceConnectorConfig values:
config.action.reload = restart
connector.class = io.debezium.connector.mysql.MySqlConnector
errors.log.enable = false
errors.log.include.messages = false
errors.retry.delay.max.ms = 60000
errors.retry.timeout = 0
errors.tolerance = none
exactly.once.support = requested
header.converter = null
key.converter = null
name = mysql-debezium
offsets.storage.topic = null
predicates = []
tasks.max = 3
topic.creation.groups = []
transaction.boundary = poll
transaction.boundary.interval.ms = null
transforms = [reroute, unwrap]
value.converter = null
 (org.apache.kafka.connect.runtime.SourceConnectorConfig:370)
[2024-03-20 17:07:12,089] INFO 192.168.56.120 - - [20/Mar/2024:08:05:42 +0000] "POST /connectors/ HTTP/1.1" 500 48 "-" "curl/7.61.1" 90016 (org.apache.kafka.connect.runtime.rest.RestServer:62)

------------------------------------------------------------------------

--
You received this message because you are subscribed to the Google Groups "debezium" group.
To unsubscribe from this group and stop receiving emails from it, send an email to debezium+u...@googlegroups.com.
To view this discussion on the web visit https://groups.google.com/d/msgid/debezium/27899823-fedf-41cc-9a1c-a9ff2239d675n%40googlegroups.com.