Kafdrop

{"state":"RUNNING","trace":null,"worker_id":"localhost:8083","generation":2}

{"state":"RUNNING","trace":null,"worker_id":"localhost:8083","generation":4}

{"state":"RUNNING","trace":null,"worker_id":"localhost:8083","generation":12}

{"state":"RUNNING","trace":null,"worker_id":"localhost:8083","generation":14}

{"state":"RUNNING","trace":null,"worker_id":"localhost:8083","generation":16}

{"state":"RUNNING","trace":null,"worker_id":"localhost:8083","generation":20}

{"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_filemngt :\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}

{"state":"UNASSIGNED","trace":null,"worker_id":"localhost:8083","generation":25}

empty

{"state":"UNASSIGNED","trace":null,"worker_id":"localhost:8083","generation":27}

empty

empty

empty

{"state":"UNASSIGNED","trace":null,"worker_id":"localhost:8083","generation":37}

empty

{"state":"UNASSIGNED","trace":null,"worker_id":"localhost:8083","generation":41}

empty

{"state":"UNASSIGNED","trace":null,"worker_id":"localhost:8083","generation":45}

empty

empty