Topic Messages: docker-connect-status

First Offset: 0  Last Offset: 20  Size: 20
  
  
  
  
  
No available descriptor, please check.
  
  
Offset: 0   Key: status-connector-Mysql-ODM-Decision-SourceConnector   Timestamp: 2024-12-03 10:59:53.039 Headers: empty
  
{"state":"RUNNING","trace":null,"worker_id":"localhost:8083","generation":6}
Offset: 1   Key: status-connector-Mysql-ODM-Filemngt-SourceConnector   Timestamp: 2024-12-03 10:59:53.145 Headers: empty
  
{"state":"RUNNING","trace":null,"worker_id":"localhost:8083","generation":8}
Offset: 2   Key: status-task-Mysql-ODM-Analysis-SourceConnector-0   Timestamp: 2024-12-03 10:59:53.434 Headers: empty
  
{"state":"RUNNING","trace":null,"worker_id":"localhost:8083","generation":12}
Offset: 3   Key: status-connector-Mysql-ODM-Party-SourceConnector   Timestamp: 2024-12-03 10:59:53.449 Headers: empty
  
{"state":"RUNNING","trace":null,"worker_id":"localhost:8083","generation":12}
Offset: 4   Key: status-task-Mysql-ODM-Party-SourceConnector-0   Timestamp: 2024-12-03 10:59:53.816 Headers: empty
  
{"state":"RUNNING","trace":null,"worker_id":"localhost:8083","generation":16}
Offset: 5   Key: status-connector-Mysql-ODM-Scoring-SourceConnector   Timestamp: 2024-12-03 10:59:53.913 Headers: empty
  
{"state":"RUNNING","trace":null,"worker_id":"localhost:8083","generation":18}
Offset: 6   Key: status-task-Mysql-ODM-Party-SourceConnector-0   Timestamp: 2024-12-03 11:00:02.411 Headers: empty
  
{"state":"FAILED","trace":"org.apache.kafka.connect.errors.ConnectException: Tolerance exceeded in error handler\n\tat org.apache.kafka.connect.runtime.errors.RetryWithToleranceOperator.execAndHandleError(RetryWithToleranceOperator.java:244)\n\tat org.apache.kafka.connect.runtime.errors.RetryWithToleranceOperator.execute(RetryWithToleranceOperator.java:166)\n\tat org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.convertTransformedRecord(AbstractWorkerSourceTask.java:510)\n\tat org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.sendRecords(AbstractWorkerSourceTask.java:408)\n\tat org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.execute(AbstractWorkerSourceTask.java:373)\n\tat org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:229)\n\tat org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:284)\n\tat org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.run(AbstractWorkerSourceTask.java:80)\n\tat org.apache.kafka.connect.runtime.isolation.Plugins.lambda$withClassLoader$1(Plugins.java:237)\n\tat java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)\n\tat java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)\n\tat java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)\n\tat java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)\n\tat java.base/java.lang.Thread.run(Thread.java:829)\nCaused by: org.apache.kafka.connect.errors.DataException: Failed to serialize Avro data from topic odm_party :\n\tat io.confluent.connect.avro.AvroConverter.fromConnectData(AvroConverter.java:107)\n\tat org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.lambda$convertTransformedRecord$8(AbstractWorkerSourceTask.java:510)\n\tat org.apache.kafka.connect.runtime.errors.RetryWithToleranceOperator.execAndRetry(RetryWithToleranceOperator.java:190)\n\tat org.apache.kafka.connect.runtime.errors.RetryWithToleranceOperator.execAndHandleError(RetryWithToleranceOperator.java:224)\n\t... 13 more\nCaused by: org.apache.kafka.common.errors.SerializationException: Error serializing Avro message\n\tat io.confluent.kafka.serializers.AbstractKafkaAvroSerializer.serializeImpl(AbstractKafkaAvroSerializer.java:174)\n\tat io.confluent.connect.avro.AvroConverter$Serializer.serialize(AvroConverter.java:177)\n\tat io.confluent.connect.avro.AvroConverter.fromConnectData(AvroConverter.java:94)\n\t... 16 more\nCaused by: java.net.UnknownHostException: schema-registry\n\tat java.base/java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:229)\n\tat java.base/java.net.Socket.connect(Socket.java:615)\n\tat java.base/sun.net.NetworkClient.doConnect(NetworkClient.java:177)\n\tat java.base/sun.net.www.http.HttpClient.openServer(HttpClient.java:509)\n\tat java.base/sun.net.www.http.HttpClient.openServer(HttpClient.java:604)\n\tat java.base/sun.net.www.http.HttpClient.<init>(HttpClient.java:277)\n\tat java.base/sun.net.www.http.HttpClient.New(HttpClient.java:376)\n\tat java.base/sun.net.www.http.HttpClient.New(HttpClient.java:397)\n\tat java.base/sun.net.www.protocol.http.HttpURLConnection.getNewHttpClient(HttpURLConnection.java:1258)\n\tat java.base/sun.net.www.protocol.http.HttpURLConnection.plainConnect0(HttpURLConnection.java:1192)\n\tat java.base/sun.net.www.protocol.http.HttpURLConnection.plainConnect(HttpURLConnection.java:1086)\n\tat java.base/sun.net.www.protocol.http.HttpURLConnection.connect(HttpURLConnection.java:1020)\n\tat java.base/sun.net.www.protocol.http.HttpURLConnection.getOutputStream0(HttpURLConnection.java:1372)\n\tat java.base/sun.net.www.protocol.http.HttpURLConnection.getOutputStream(HttpURLConnection.java:1347)\n\tat io.confluent.kafka.schemaregistry.client.rest.RestService.sendHttpRequest(RestService.java:304)\n\tat io.confluent.kafka.schemaregistry.client.rest.RestService.httpRequest(RestService.java:409)\n\tat io.confluent.kafka.schemaregistry.client.rest.RestService.registerSchema(RestService.java:589)\n\tat io.confluent.kafka.schemaregistry.client.rest.RestService.registerSchema(RestService.java:577)\n\tat io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient.registerAndGetId(CachedSchemaRegistryClient.java:312)\n\tat io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient.registerWithResponse(CachedSchemaRegistryClient.java:428)\n\tat io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient.registerWithResponse(CachedSchemaRegistryClient.java:405)\n\tat io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe.registerWithResponse(AbstractKafkaSchemaSerDe.java:516)\n\tat io.confluent.kafka.serializers.AbstractKafkaAvroSerializer.serializeImpl(AbstractKafkaAvroSerializer.java:118)\n\t... 18 more\n","worker_id":"localhost:8083","generation":25}
Offset: 7   Key: status-task-Mysql-ODM-Analysis-SourceConnector-0   Timestamp: 2024-12-03 11:00:02.411 Headers: empty
  
{"state":"FAILED","trace":"org.apache.kafka.connect.errors.ConnectException: Tolerance exceeded in error handler\n\tat org.apache.kafka.connect.runtime.errors.RetryWithToleranceOperator.execAndHandleError(RetryWithToleranceOperator.java:244)\n\tat org.apache.kafka.connect.runtime.errors.RetryWithToleranceOperator.execute(RetryWithToleranceOperator.java:166)\n\tat org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.convertTransformedRecord(AbstractWorkerSourceTask.java:510)\n\tat org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.sendRecords(AbstractWorkerSourceTask.java:408)\n\tat org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.execute(AbstractWorkerSourceTask.java:373)\n\tat org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:229)\n\tat org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:284)\n\tat org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.run(AbstractWorkerSourceTask.java:80)\n\tat org.apache.kafka.connect.runtime.isolation.Plugins.lambda$withClassLoader$1(Plugins.java:237)\n\tat java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)\n\tat java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)\n\tat java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)\n\tat java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)\n\tat java.base/java.lang.Thread.run(Thread.java:829)\nCaused by: org.apache.kafka.connect.errors.DataException: Failed to serialize Avro data from topic odm_analysis :\n\tat io.confluent.connect.avro.AvroConverter.fromConnectData(AvroConverter.java:107)\n\tat org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.lambda$convertTransformedRecord$8(AbstractWorkerSourceTask.java:510)\n\tat org.apache.kafka.connect.runtime.errors.RetryWithToleranceOperator.execAndRetry(RetryWithToleranceOperator.java:190)\n\tat org.apache.kafka.connect.runtime.errors.RetryWithToleranceOperator.execAndHandleError(RetryWithToleranceOperator.java:224)\n\t... 13 more\nCaused by: org.apache.kafka.common.errors.SerializationException: Error serializing Avro message\n\tat io.confluent.kafka.serializers.AbstractKafkaAvroSerializer.serializeImpl(AbstractKafkaAvroSerializer.java:174)\n\tat io.confluent.connect.avro.AvroConverter$Serializer.serialize(AvroConverter.java:177)\n\tat io.confluent.connect.avro.AvroConverter.fromConnectData(AvroConverter.java:94)\n\t... 16 more\nCaused by: java.net.UnknownHostException: schema-registry\n\tat java.base/java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:229)\n\tat java.base/java.net.Socket.connect(Socket.java:615)\n\tat java.base/sun.net.NetworkClient.doConnect(NetworkClient.java:177)\n\tat java.base/sun.net.www.http.HttpClient.openServer(HttpClient.java:509)\n\tat java.base/sun.net.www.http.HttpClient.openServer(HttpClient.java:604)\n\tat java.base/sun.net.www.http.HttpClient.<init>(HttpClient.java:277)\n\tat java.base/sun.net.www.http.HttpClient.New(HttpClient.java:376)\n\tat java.base/sun.net.www.http.HttpClient.New(HttpClient.java:397)\n\tat java.base/sun.net.www.protocol.http.HttpURLConnection.getNewHttpClient(HttpURLConnection.java:1258)\n\tat java.base/sun.net.www.protocol.http.HttpURLConnection.plainConnect0(HttpURLConnection.java:1192)\n\tat java.base/sun.net.www.protocol.http.HttpURLConnection.plainConnect(HttpURLConnection.java:1086)\n\tat java.base/sun.net.www.protocol.http.HttpURLConnection.connect(HttpURLConnection.java:1020)\n\tat java.base/sun.net.www.protocol.http.HttpURLConnection.getOutputStream0(HttpURLConnection.java:1372)\n\tat java.base/sun.net.www.protocol.http.HttpURLConnection.getOutputStream(HttpURLConnection.java:1347)\n\tat io.confluent.kafka.schemaregistry.client.rest.RestService.sendHttpRequest(RestService.java:304)\n\tat io.confluent.kafka.schemaregistry.client.rest.RestService.httpRequest(RestService.java:409)\n\tat io.confluent.kafka.schemaregistry.client.rest.RestService.registerSchema(RestService.java:589)\n\tat io.confluent.kafka.schemaregistry.client.rest.RestService.registerSchema(RestService.java:577)\n\tat io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient.registerAndGetId(CachedSchemaRegistryClient.java:312)\n\tat io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient.registerWithResponse(CachedSchemaRegistryClient.java:428)\n\tat io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient.registerWithResponse(CachedSchemaRegistryClient.java:405)\n\tat io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe.registerWithResponse(AbstractKafkaSchemaSerDe.java:516)\n\tat io.confluent.kafka.serializers.AbstractKafkaAvroSerializer.serializeImpl(AbstractKafkaAvroSerializer.java:118)\n\t... 18 more\n","worker_id":"localhost:8083","generation":25}
Offset: 8   Key: status-task-Mysql-ODM-Analysis-SourceConnector-0   Timestamp: 2024-12-03 11:16:20.159 Headers: empty
  
empty
Offset: 9   Key: status-task-Mysql-ODM-Analysis-SourceConnector-0   Timestamp: 2024-12-03 11:16:20.159 Headers: empty
  
empty
Offset: 10   Key: status-connector-Mysql-ODM-Decision-SourceConnector   Timestamp: 2024-12-03 11:16:20.188 Headers: empty
  
{"state":"UNASSIGNED","trace":null,"worker_id":"localhost:8083","generation":29}
Offset: 11   Key: status-connector-Mysql-ODM-Decision-SourceConnector   Timestamp: 2024-12-03 11:16:20.194 Headers: empty
  
empty
Offset: 12   Key: status-connector-Mysql-ODM-Filemngt-SourceConnector   Timestamp: 2024-12-03 11:16:20.205 Headers: empty
  
{"state":"UNASSIGNED","trace":null,"worker_id":"localhost:8083","generation":31}
Offset: 13   Key: status-connector-Mysql-ODM-Filemngt-SourceConnector   Timestamp: 2024-12-03 11:16:20.211 Headers: empty
  
empty
Offset: 14   Key: status-connector-Mysql-ODM-Party-SourceConnector   Timestamp: 2024-12-03 11:16:20.251 Headers: empty
  
{"state":"UNASSIGNED","trace":null,"worker_id":"localhost:8083","generation":35}
Offset: 15   Key: status-task-Mysql-ODM-Party-SourceConnector-0   Timestamp: 2024-12-03 11:16:20.262 Headers: empty
  
empty
Offset: 16   Key: status-connector-Mysql-ODM-Party-SourceConnector   Timestamp: 2024-12-03 11:16:20.262 Headers: empty
  
empty
Offset: 17   Key: status-task-Mysql-ODM-Party-SourceConnector-0   Timestamp: 2024-12-03 11:16:20.262 Headers: empty
  
empty
Offset: 18   Key: status-connector-Mysql-ODM-Scoring-SourceConnector   Timestamp: 2024-12-03 11:16:20.322 Headers: empty
  
{"state":"UNASSIGNED","trace":null,"worker_id":"localhost:8083","generation":43}
Offset: 19   Key: status-connector-Mysql-ODM-Scoring-SourceConnector   Timestamp: 2024-12-03 11:16:20.329 Headers: empty
  
empty