ConfluentSchemaRegistry IntegrationTest prints huge logs

[walterddr]

trafficstars

https://github.com/apache/pinot/runs/7890686433?check_suite_focus=true

2022-08-18T02:12:33.6547446Z [INFO] Running org.apache.pinot.integration.tests.KafkaConfluentSchemaRegistryAvroMessageDecoderRealtimeClusterIntegrationTest
...
2022-08-18T02:14:26.6174836Z 02:14:25.310 ERROR [KafkaConfluentSchemaRegistryAvroMessageDecoder] [mytable__0__0__20220818T0214Z] Caught exception while decoding row in topic KafkaConfluentSchemaRegistryAvroMessageDecoderRealtimeClusterIntegrationTest, discarding row
2022-08-18T02:14:26.6175975Z org.apache.kafka.common.errors.SerializationException: Error deserializing Avro message for id -1
2022-08-18T02:14:26.6176584Z Caused by: org.apache.kafka.common.errors.SerializationException: Unknown magic byte!
2022-08-18T02:14:26.6177510Z 02:14:25.867 ERROR [KafkaConfluentSchemaRegistryAvroMessageDecoder] [mytable__1__0__20220818T0214Z] Caught exception while decoding row in topic KafkaConfluentSchemaRegistryAvroMessageDecoderRealtimeClusterIntegrationTest, discarding row
2022-08-18T02:14:26.6178539Z org.apache.kafka.common.errors.SerializationException: Error deserializing Avro message for id -1
2022-08-18T02:14:26.6179139Z Caused by: org.apache.kafka.common.errors.SerializationException: Unknown magic byte!
...

going on for 120,000 lines.

[walterddr]

CC @KKcorps ^ since we recently also added the schema registry in protobuf test

[agavra]

2022-08-18T02:14:26.6175975Z org.apache.kafka.common.errors.SerializationException: Error deserializing Avro message for id -1
2022-08-18T02:14:26.6176584Z Caused by: org.apache.kafka.common.errors.SerializationException: Unknown magic byte!

This happens when trying to use the confluent schema registry to deserialize a message that was written using the standard (non-schemaregistry) avro serializer. I'll take a quick look at this.