I am trying to load data into kafka topic through filebeat. The major issue I am facing is, filebeat is converting special character (&) into Unicode value (\u0026) when loading into kafka topic output.
My log data has the field "department": "E&C". When this field is loaded into kafka from filebeat, it is looking as E\u0026C. I am using latest version of filebeat 7.13.3.
How I can resolve this issue?. I have tried lot of different possibilities but nothing works out. please advise
Thanks for your response. Yes, I have tried pushing the result into console as well as tried using other output plug-in like writing result to a file, In both case, I could see '&' in the result ('&' is not converted to '\u0026'). But I am not sure why this conversion happening when loading the data into kafka using output.kafka plug in. I couldn't find any solution for this problem.
Apache, Apache Lucene, Apache Hadoop, Hadoop, HDFS and the yellow elephant
logo are trademarks of the
Apache Software Foundation
in the United States and/or other countries.