Fixed an issue in the AvroConfluent format that caused the Kafka table engine to stop processing messages when an abnormally small or malformed message was received.
Why it matters
This fix ensures that the Kafka table engine continues processing messages even if it encounters abnormally small or malformed messages in the AvroConfluent format, improving stability and reliability during message ingestion.How to use it
No additional configuration is required. After upgrading to the version containing this fix, the Kafka table engine will handle malformed or unusually small AvroConfluent messages without interruption.