Spark Streaming с Kafka: AvroRunTimeException с наличием латинских символов

Я думаю, проблема здесь не в латинских символах. Поэтому проблема заключается в том, что несовпадение сериализатора и десериализатора используется.

Данные, которые нажимаются на тему, сериализуются с использованием строковой сериализации, и это десериализован с использованием ByeArrayDeserializer. Это несоответствие вызывает проблему.