Question
7
Views

optum
IN
Posted: 2 weeks 6 days ago
Last activity: 2 weeks 6 days ago
Last activity: 16 May 2023 7:38 EDT
Conversion of ClipboardPage to GenericRecord has failed trying to publish message kafka avro schema
I am trying to publish message to a Kafka Avro Schema using DataSet-Execute method (Save), The activity is returning Success but no data is being published to topic
Getting below error, Please suggest any solution
Show More
I am trying to publish message to a Kafka Avro Schema using DataSet-Execute method (Save), The activity is returning Success but no data is being published to topic
Getting below error, Please suggest any solution
Conversion of ClipboardPage to GenericRecord has failed. org.apache.kafka.common.errors.SerializationException: Error registering Avro schema: {"type":"record","name":"call_identifiers_nonprod","namespace":"XXXX_consumer_YYYYY","fields":[{"name":"IdentificationNumber","type":"string"},{"name":"ZZZ","type":"string"},{"name":"WWW","type":"string"},{"name":"pyID","type":"string"},{"name":"pyLabel","type":"string"},{"name":"CurrentInteractionID","type":"string"},{"name":"pxCreateOperator","type":"string"},{"name":"pxCreateDateTime","type":"string"}]} Caused by: io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException: Master not known.; error code: 50004 at io.confluent.kafka.schemaregistry.client.rest.RestService.sendHttpRequest(RestService.java:209) ~[kafka-schema-registry-client-5.1.4.jar:?] at io.confluent.kafka.schemaregistry.client.rest.RestService.httpRequest(RestService.java:235) ~[kafka-schema-registry-client-5.1.4.jar:?] at io.confluent.kafka.schemaregistry.client.rest.RestService.registerSchema(RestService.java:326) ~[kafka-schema-registry-client-5.1.4.jar:?] at io.confluent.kafka.schemaregistry.client.rest.RestService.registerSchema(RestService.java:318) ~[kafka-schema-registry-client-5.1.4.jar:?] at io.confluent.kafka.schemaregistry.client.rest.RestService.registerSchema(RestService.java:313) ~[kafka-schema-registry-client-5.1.4.jar:?]
2.
Caused by: org.apache.kafka.common.errors.SerializationException: Error registering Avro schema: {"type":"record","name":"call_identifiers_nonprod","namespace":"XXXX_consumer_YYYY","fields":[{"name":"IdentificationNumber","type":"string"},{"name":"ZZZ","type":"string"},{"name":"WWW","type":"string"},{"name":"pyID","type":"string"},{"name":"pyLabel","type":"string"},{"name":"CurrentInteractionID","type":"string"},{"name":"pxCreateOperator","type":"string"},{"name":"pxCreateDateTime","type":"string"}]} Caused by: io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException: Master not known.; error code: 50004 at io.confluent.kafka.schemaregistry.client.rest.RestService.sendHttpRequest(RestService.java:209) ~[kafka-schema-registry-client-5.1.4.jar:?]
Show Less
***Edited by Moderator Marije to add Capability tags***