OneStop kafka typecast ParsedRecord to ParsedRecordWithId fails

[erinreeves]

Bug Description Upon executing onestop-clients script launch_kafka_publisher.py on cedar-devs the Registry on cedar-devs crashes and restarts infinitely until kafka messages are deleted from pod 'pc-cp-kafka-0' by doing these steps:

STEPS to FIX Registry: Note: the offset needs to be one more than what is in the exception in the Registry pod logs. json='{"partitions":[{"topic":"psi-granules-by-collection","partition":3,"offset":11}],"version":1}' echo $json > kafka_delete_records.json kafka-delete-records --bootstrap-server localhost:9092 --offset-json-file kafka_delete_records.json

Platform/Environment cedar-devs

Severity Severity: HIGH (High/Medium/Low) Priority: MEDIUM (High/Medium/Low)

To Reproduce Steps to reproduce the behavior:

1. ssh cedar-devs
2. exec into sme pod (helm install if it isn't running, pull down onestop-clients and cd into it, if repo not on that user account)
3. python scripts/launch_kafka_publisher.py -conf config.yml

Expected Result While the script completes and doesn't thrown an error Registry crashes, which shouldn't.

Actual Result Registry crashes. If you view its logs it has this in there: Caused by: java.lang.ClassCastException: class org.cedar.schemas.avro.psi.ParsedRecord cannot be cast to class org.cedar.schemas.avro.psi.ParsedRecordWithId (org.cedar.schemas.avro.psi.ParsedRecord and org.cedar.schemas.avro.psi.ParsedRecordWithId are in unnamed module of loader 'app')

Screenshots If applicable, add screenshots to help explain your problem.

Additional context Add any other context about the problem here.