resolve kafka audit header confit (#337)

core-models/src/main/pegasus/com/linkedin/avro2pegasus/events/KafkaAuditHeader.pdl

@@ -8,50 +8,51 @@ record KafkaAuditHeader {
   /**
    * The time at which the event was emitted into kafka.
    */
-  @compliance = [ {
-    "policy" : "EVENT_TIME"
-  } ]
+  @compliance = [
+    {"dataType": "EVENT_TIME" },
+    {"dataType": "UNKNOWN_ORIGIN_NON_MEMBER_DATA" }
+  ]
   time: long
 
   /**
    * The fully qualified name of the host from which the event is being emitted.
    */
-  @compliance = "NONE"
+  @compliance.dataType = "UNKNOWN_ORIGIN_NON_MEMBER_DATA"
   server: string
 
   /**
    * The instance on the server from which the event is being emitted. e.g. i001
    */
-  @compliance = "NONE"
+  @compliance.dataType = "UNKNOWN_ORIGIN_NON_MEMBER_DATA"
   instance: optional string
 
   /**
    * The name of the application from which the event is being emitted. see go/appname
    */
-  @compliance = "NONE"
+  @compliance.dataType = "UNKNOWN_ORIGIN_NON_MEMBER_DATA"
   appName: string
 
   /**
    * A unique identifier for the message
    */
-  @compliance = "NONE"
+  @compliance.dataType = "UNKNOWN_ORIGIN_NON_MEMBER_DATA"
   messageId: UUID
 
   /**
    * The version that is being used for auditing. In version 0, the audit trail buckets events into 10 minute audit windows based on the EventHeader timestamp. In version 1, the audit trail buckets events as follows: if the schema has an outer KafkaAuditHeader, use the outer audit header timestamp for bucketing; else if the EventHeader has an inner KafkaAuditHeader use that inner audit header's timestamp for bucketing
    */
-  @compliance = "NONE"
+  @compliance.dataType = "UNKNOWN_ORIGIN_NON_MEMBER_DATA"
   auditVersion: optional int
 
   /**
    * The fabricUrn of the host from which the event is being emitted. Fabric Urn in the format of urn:li:fabric:{fabric_name}. See go/fabric.
    */
-  @compliance = "NONE"
+  @compliance.dataType = "UNKNOWN_ORIGIN_NON_MEMBER_DATA"
   fabricUrn: optional string
 
   /**
    * This is a String that the client uses to establish some kind of connection with the Kafka cluster. The exact format of it depends on specific versions of clients and brokers. This information could potentially identify the fabric and cluster with which the client is producing to or consuming from.
    */
-  @compliance = "NONE"
+  @compliance.dataType = "UNKNOWN_ORIGIN_NON_MEMBER_DATA"
   clusterConnectionString: optional string
 }