我们使用apachekafka（不是合流的kafka）0.10。我们想与Kafka建立avro模式。我有如下avro模式。

{
  "namespace": "Rule",
  "type": "record",
  "name": "RuleMessage",
  "fields": [
    {
      "name": "station",
      "type": "string"
    },
    {
      "name": "model",
      "type": "string"
    }
}

序列化消息，例如，

public byte[] serializeMessage(EventMessage eventMessage) throws IOException {

        ByteArrayOutputStream out = new ByteArrayOutputStream();
        BinaryEncoder encoder = EncoderFactory.get().binaryEncoder(out, null);
        DatumWriter<EventMessage> writer = new SpecificDatumWriter<EventMessage>(EventMessage.getClassSchema());
        writer.write(eventMessage, encoder);
        encoder.flush();
        out.close();
        return out.toByteArray();
    }

这是预期的工作。
但是，希望在主题级别设置一个avro模式，以便在消息不符合avro模式时，主题将拒绝消息。
不管怎样，我可以用ApacheKafka0.10做这个。
谢谢