search

taosdata / kafka-connect-tdengine

GNU Affero General Public License v3.0
15 stars 5 forks source link

Request timed out. The worker is currently ensuring membership in the cluster #60

Open alwayslikethis777 opened 5 months ago

alwayslikethis777 commented 5 months ago 
 curl -X POST -d @source-demo.json http://172.17.0.3:8083/connectors -H "Content-Type: application/json"
{"error_code":500,"message":"Request timed out. The worker is currently ensuring membership in the cluster, which began at 2024-06-07T03:48:47.889Z"}
curl -X GET http://172.17.0.3:8083/connectors
[]
curl -X GET http://172.17.0.3:8083
{"version":"3.7.0","commit":"2ae524ed625438c5","kafka_cluster_id":"Some(iZWRiSqjZAlYwlKEqHFQWI)"}
alwayslikethis777 commented 5 months ago

kafka-connect's log

[2024-06-07 11:48:31,598] INFO Finished reading KafkaBasedLog for topic connect-configs (org.apache.kafka.connect.util.KafkaBasedLog:286)
[2024-06-07 11:48:31,603] INFO Started KafkaBasedLog for topic connect-configs (org.apache.kafka.connect.util.KafkaBasedLog:288)
[2024-06-07 11:48:31,603] INFO Started KafkaConfigBackingStore (org.apache.kafka.connect.storage.KafkaConfigBackingStore:402)
[2024-06-07 11:48:31,603] INFO [Worker clientId=connect-172.17.0.3:8083, groupId=connect-cluster] Herder started (org.apache.kafka.connect.runtime.distributed.DistributedHerder:376)
[2024-06-07 11:48:31,653] INFO [Worker clientId=connect-172.17.0.3:8083, groupId=connect-cluster] Cluster ID: Some(iZWRiSqjZAlYwlKEqHFQWI) (org.apache.kafka.clients.Metadata:349)
Jun 07, 2024 11:48:31 AM org.glassfish.jersey.internal.inject.Providers checkProviderRuntime
WARNING: A provider org.apache.kafka.connect.runtime.rest.resources.RootResource registered in SERVER runtime does not implement any provider interfaces applicable in the SERVER runtime. Due to constraint configuration problems the provider org.apache.kafka.connect.runtime.rest.resources.RootResource will be ignored. 
Jun 07, 2024 11:48:31 AM org.glassfish.jersey.internal.inject.Providers checkProviderRuntime
WARNING: A provider org.apache.kafka.connect.runtime.rest.resources.ConnectorsResource registered in SERVER runtime does not implement any provider interfaces applicable in the SERVER runtime. Due to constraint configuration problems the provider org.apache.kafka.connect.runtime.rest.resources.ConnectorsResource will be ignored. 
Jun 07, 2024 11:48:31 AM org.glassfish.jersey.internal.inject.Providers checkProviderRuntime
WARNING: A provider org.apache.kafka.connect.runtime.rest.resources.InternalConnectResource registered in SERVER runtime does not implement any provider interfaces applicable in the SERVER runtime. Due to constraint configuration problems the provider org.apache.kafka.connect.runtime.rest.resources.InternalConnectResource will be ignored. 
Jun 07, 2024 11:48:31 AM org.glassfish.jersey.internal.inject.Providers checkProviderRuntime
WARNING: A provider org.apache.kafka.connect.runtime.rest.resources.ConnectorPluginsResource registered in SERVER runtime does not implement any provider interfaces applicable in the SERVER runtime. Due to constraint configuration problems the provider org.apache.kafka.connect.runtime.rest.resources.ConnectorPluginsResource will be ignored. 
Jun 07, 2024 11:48:31 AM org.glassfish.jersey.internal.inject.Providers checkProviderRuntime
WARNING: A provider org.apache.kafka.connect.runtime.rest.resources.LoggingResource registered in SERVER runtime does not implement any provider interfaces applicable in the SERVER runtime. Due to constraint configuration problems the provider org.apache.kafka.connect.runtime.rest.resources.LoggingResource will be ignored. 
Jun 07, 2024 11:48:32 AM org.glassfish.jersey.internal.Errors logErrors
WARNING: The following warnings have been detected: WARNING: The (sub)resource method listLoggers in org.apache.kafka.connect.runtime.rest.resources.LoggingResource contains empty path annotation.
WARNING: The (sub)resource method listConnectors in org.apache.kafka.connect.runtime.rest.resources.ConnectorsResource contains empty path annotation.
WARNING: The (sub)resource method createConnector in org.apache.kafka.connect.runtime.rest.resources.ConnectorsResource contains empty path annotation.
WARNING: The (sub)resource method listConnectorPlugins in org.apache.kafka.connect.runtime.rest.resources.ConnectorPluginsResource contains empty path annotation.
WARNING: The (sub)resource method serverInfo in org.apache.kafka.connect.runtime.rest.resources.RootResource contains empty path annotation.

[2024-06-07 11:48:32,540] INFO Started o.e.j.s.ServletContextHandler@6b33892a{/,null,AVAILABLE} (org.eclipse.jetty.server.handler.ContextHandler:921)
[2024-06-07 11:48:32,541] INFO REST resources initialized; server is started and ready to handle requests (org.apache.kafka.connect.runtime.rest.RestServer:302)
[2024-06-07 11:48:32,541] INFO Kafka Connect started (org.apache.kafka.connect.runtime.Connect:57)
[2024-06-07 13:38:34,412] INFO [AdminClient clientId=connect-cluster-shared-admin] Node 1 disconnected. (org.apache.kafka.clients.NetworkClient:997)
[2024-06-07 13:43:34,623] INFO [AdminClient clientId=connect-cluster-shared-admin] Node 1 disconnected. (org.apache.kafka.clients.NetworkClient:997)
[2024-06-07 13:48:34,832] INFO [AdminClient clientId=connect-cluster-shared-admin] Node 1 disconnected. (org.apache.kafka.clients.NetworkClient:997)
[2024-06-07 13:52:23,004] INFO 172.17.0.1 - - [07/Jun/2024:05:52:22 +0000] "GET /connectors HTTP/1.1" 200 2 "-" "curl/7.29.0" 13 (org.apache.kafka.connect.runtime.rest.RestServer:62)
[2024-06-07 13:52:32,875] INFO 172.17.0.1 - - [07/Jun/2024:05:52:32 +0000] "GET / HTTP/1.1" 200 97 "-" "curl/7.29.0" 15 (org.apache.kafka.connect.runtime.rest.RestServer:62)
[2024-06-07 13:53:35,032] INFO [AdminClient clientId=connect-cluster-shared-admin] Node 1 disconnected. (org.apache.kafka.clients.NetworkClient:997)