情况
我目前正在使用avro和模式存储库编写一个消费者/生产者。
据我所知，序列化这些数据的方法要么使用confluent的avro序列化程序，要么使用twitter的双射。
似乎双射看起来最直接。
所以我想用以下格式生成日期 ProducerRecord[String,Array[Byte]] ，这归结为[some string id，serialized genericord]
（注意：我使用的是通用记录，因为这个代码库必须处理从json/csv/…解析的数千个模式）
问题：
我序列化并使用avro的全部原因是，您不需要在数据本身中有模式（就像使用json/xml/…）。
但是，在检查主题中的数据时，我看到整个方案都包含在数据中。我是在做一些根本错误的事情，这是设计的，还是应该改用合流序列化程序？
代码：

def jsonStringToAvro(jString: String, schema: Schema): GenericRecord = {
    val converter = new JsonAvroConverter
    val genericRecord = converter.convertToGenericDataRecord(jString.replaceAll("\\\\/","_").getBytes(), schema)

    genericRecord
  }
def serializeAsByteArray(avroRecord: GenericRecord): Array[Byte] = {
    //val genericRecordInjection = GenericAvroCodecs.toBinary(avroRecord.getSchema)
    val r: Array[Byte] = GenericAvroCodecs.toBinary(avroRecord.getSchema).apply(avroRecord)

    r
  }

//schema comes from a rest call to the schema repository
new ProducerRecord[String, Array[Byte]](topic, myStringKeyGoesHere, serializeAsByteArray(jsonStringToAvro(jsonObjectAsStringGoesHere, schema)))

        producer.send(producerRecord, new Callback {...})