When I am checking Kafka logs it is there:
Invalid record due to REST client error
(io.confluent.kafka.schemaregistry.validator.RecordSchemaValidator)
io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException:
This ID is banned; error code: 40403
at
io.confluent.kafka.schemaregistry.validator.LruSchemaRegistryClient.getSchemaByIdFromRegistry(LruSchemaRegistryClient.java:188)
On Thu, Jul 16, 2020, 09:31 vishnu murali <[email protected]>
wrote:
> Hi all
>
> My schema is:
>
>
>
> {
> "fields": [
>
> {
> "name": "ID",
>
> "type": "long"
>
> },
>
> {
> "name": "Group",
>
> "type": [
>
> "null",
>
> {
> "avro.java.string": "String",
>
> "type": "string"
>
> }
>
> ]
>
> },
>
> {
> "name": "Key",
>
> "type": [
>
> "null",
>
> {
> "avro.java.string": "String",
>
> "type": "string"
>
> }
>
> ]
>
> },
>
> {
> "name": "Value",
>
> "type": [
>
> "null",
>
> {
> "avro.java.string": "String",
>
> "type": "string"
>
> }
>
> ]
>
> }
>
> ],
>
> "name": "Runconfig",
>
> "namespace": "com.ns.vishnu.kafkaavorest.Model",
>
> "type": "record"
>
> }
>
>
>
>
>
> My Data is:
>
> Runconfig rc = Runconfig.newBuilder()
> .setID(1L)
> .setGroup("new")
> .setKey("year")
> .setValue("11")
> .build();
>
>
>
> runTemlate.send(“n-run”,rc);
>
>
>
>
>
> Exception will be: org.apache.kafka.common.InvalidRecordException: This
> record has failed the validation on broker and hence be rejected.
>
>
>
>
>
> What is the validation mistake in this ?
>
> I checked every datatype it is correct only!!
>
> Any suggestions on this !!
>
