Question
optum
IN
Last activity: 18 Aug 2023 0:46 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
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:?]
Pegasystems Inc.
GB
@SrinivasB9507 The error you are encountering is related to the Avro schema registration with the schema registry. The error message "Master not known" suggests that there might be an issue with the schema registry itself or its configuration. To resolve this issue, you can try the following steps:
- Verify that the schema registry is running and accessible.
- Check the schema registry configuration, especially the settings related to the master node and any potential network issues.
- Ensure that the Kafka and schema registry client libraries used in your Pega application are compatible with the schema registry version you are using.
If the issue persists, you may need to consult the schema registry documentation or seek assistance from the schema registry provider to identify and resolve the problem.
Conversion of ClipboardPage to GenericRecord has failed trying to publish mess
Configure schema registry to read from Kafka topic using AVRO SCHEMA
Pegasystems Inc.
IN
@SrinivasB9507Hi Srinivas. It's trying to validate message against the AVRO schema. configure the connection details of AVRO registry, load schema and then post messages