nifi-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Milan Das <>
Subject published by PublishKafkaRecord_0_10 doesn't embed schema.
Date Sun, 25 Mar 2018 22:45:52 GMT
Hello Nifi Users,

Apparently, it seems like PublishKafkaRecord_0_10 doesn't embed schema even if it Avro Record
writer is configured with “Embed Avro Schema”.

I have seen the following post from Bryan Brende.  Wondering if it is a known issue or if
I am missing anything here.



This is how message looks in Kafka-console-consumer, when published using “PublishKafkaRecord_0_11”



 $ bin/ --bootstrap-server localhost:9092 --topic test --from-beginning













When I publish the message using my java class output from console consumer prints the avro


more info, refer to","fields":[{"name":"action","type":"string","doc":"The
action performed on the resource."},{"name":"dest","type":"string","doc":"The target involved
in the authentication. May be aliased from more specific fields, such as dest_host, dest_ip,
or dest_nt_host."},{"name":"signature_id","type":"int","doc":"Description of the change performed
(integer)"},{"name":"time","type":"string","doc":"ISO 8601 timestamp of the eventl <…………TRUNCATED…………….. 
>,{"name":"privileges","type":["null",{"type":"array","items":"string"}],"doc":"The list
of privileges associated with a Privilege Escalation event","default":null},{"name":"subcode","type":["null","string"],"doc":"The
error subcode for auth;��d��g%�z��H22018-03-15T09:07:04-04:00usedid1Pz��




Milan Das

  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message