{"id":47119,"date":"2023-06-22T02:13:32","date_gmt":"2023-03-28T15:55:27","guid":{"rendered":"https:\/\/www.silicloud.com\/zh\/blog\/%e4%bd%bf%e7%94%a8nifi-http%e5%a4%84%e7%90%86%e5%99%a8%e6%9d%a5%e8%8e%b7%e5%8f%96%e5%b9%b6%e8%a7%a3%e5%8e%8b%e6%96%87%e4%bb%b6%ef%bc%8c%e7%84%b6%e5%90%8e%e5%b0%86%e6%8c%87%e5%ae%9a%e6%a8%a1%e5%bc%8f\/"},"modified":"2024-04-30T10:05:09","modified_gmt":"2024-04-30T02:05:09","slug":"%e4%bd%bf%e7%94%a8nifi-http%e5%a4%84%e7%90%86%e5%99%a8%e6%9d%a5%e8%8e%b7%e5%8f%96%e5%b9%b6%e8%a7%a3%e5%8e%8b%e6%96%87%e4%bb%b6%ef%bc%8c%e7%84%b6%e5%90%8e%e5%b0%86%e6%8c%87%e5%ae%9a%e6%a8%a1%e5%bc%8f","status":"publish","type":"post","link":"https:\/\/www.silicloud.com\/zh\/blog\/%e4%bd%bf%e7%94%a8nifi-http%e5%a4%84%e7%90%86%e5%99%a8%e6%9d%a5%e8%8e%b7%e5%8f%96%e5%b9%b6%e8%a7%a3%e5%8e%8b%e6%96%87%e4%bb%b6%ef%bc%8c%e7%84%b6%e5%90%8e%e5%b0%86%e6%8c%87%e5%ae%9a%e6%a8%a1%e5%bc%8f\/","title":{"rendered":"\u4f7f\u7528NiFi HTTP\u5904\u7406\u5668\u6765\u83b7\u53d6\u5e76\u89e3\u538b\u6587\u4ef6\uff0c\u7136\u540e\u5c06\u6307\u5b9a\u6a21\u5f0f\u7684\u6587\u4ef6\u6574\u7406\u540e\u53d1\u9001\u5230Kafka"},"content":{"rendered":"<h1>\u4e3a\u4e86\u8fbe\u5230\u7279\u5b9a\u7684\u76ee\u6807\u6216\u7ed3\u679c<\/h1>\n<p>\u4f7f\u7528NiFi HTTP\u5904\u7406\u5668\u83b7\u53d6\u548c\u89e3\u538b\u6587\u4ef6\uff0c\u7136\u540e\u5c06\u7279\u5b9a\u6a21\u5f0f\u7684\u6587\u4ef6\u8fdb\u884c\u6574\u7406\uff0c\u5e76\u5c06\u5176\u53d1\u9001\u5230Kafka\u3002<\/p>\n<p>\u5728\u672c\u6559\u7a0b\u4e2d\uff0c\u5c1d\u8bd5\u4f7f\u7528PublishKafkaRecord_0_10\u5904\u7406\u5668\u3002<br \/>\n\u4ece\u8fdc\u7a0bHTTP\u670d\u52a1\u5668\u83b7\u53d6\u538b\u7f29\u4e3aZIP\u7684CSV\u6587\u4ef6\uff0c<br \/>\n\u7136\u540e\u89e3\u538b\u7f29\u3002<br \/>\n\u7136\u540e\uff0c\u53ea\u5c06\u7279\u5b9a\u7684CSV\u6587\u4ef6\u4f20\u9012\u7ed9PublishKafkaRecord_0_10\u5904\u7406\u5668\uff0c\u5c06\u5176\u6d41\u5f0f\u4f20\u8f93\u5230Kafka\u3002<\/p>\n<ul class=\"post-ul\">\u3053\u306e\u30c1\u30e5\u30fc\u30c8\u30ea\u30a2\u30eb\u306fNiFi 1.2\u304b\u3089\u5b9f\u884c\u53ef\u80fd\u3002<\/ul>\n<h1>\u73af\u5883<\/h1>\n<ul class=\"post-ul\">\n<li style=\"list-style-type: none;\">\n<ul class=\"post-ul\">Mac OS X<\/ul>\n<\/li>\n<\/ul>\n<p>&nbsp;<\/p>\n<ul class=\"post-ul\">\n<li style=\"list-style-type: none;\">\n<ul class=\"post-ul\">HDF 3.2<\/ul>\n<\/li>\n<\/ul>\n<p>Apache NiFi 1.7.0<br \/>\nApache Kafka 1.1.0<br \/>\nSchema Registry<\/p>\n<h1>\u53d1\u5e03Kafka\u8bb0\u5f55_0_10\uff08CSV\u8f6cJSON\uff09<\/h1>\n<h2>\u51c6\u5907Kafka\u73af\u5883<\/h2>\n<p>\u5b89\u88c5HDF 3.2\u3002<br \/>\n\u5b89\u88c5\u6b65\u9aa4\u8bf7\u53c2\u8003\u8fd9\u91cc\u3002<\/p>\n<h2>\u5bfc\u5165\u6a21\u677f\u6587\u4ef6<\/h2>\n<div><img decoding=\"async\" class=\"post-images\" title=\"\" src=\"https:\/\/cdn.silicloud.com\/blog-img\/blog\/img\/657d7c76913a08637a69c752\/10-0.png\" alt=\"86CC1E15-F71B-46EF-9A32-C5DF41D4B100.png\" \/><\/div>\n<div><img decoding=\"async\" class=\"post-images\" title=\"\" src=\"https:\/\/cdn.silicloud.com\/blog-img\/blog\/img\/657d7c76913a08637a69c752\/11-0.png\" alt=\"image.png\" \/><\/div>\n<h2>\u5bfc\u5165\u540e\u7684\u60c5\u51b5<\/h2>\n<div><img decoding=\"async\" class=\"post-images\" title=\"\" src=\"https:\/\/cdn.silicloud.com\/blog-img\/blog\/img\/657d7c76913a08637a69c752\/13-0.png\" alt=\"image.png\" \/><\/div>\n<h2>\u83b7\u53d6HTTP<\/h2>\n<div><img decoding=\"async\" class=\"post-images\" title=\"\" src=\"https:\/\/cdn.silicloud.com\/blog-img\/blog\/img\/657d7c76913a08637a69c752\/15-0.png\" alt=\"image.png\" \/><\/div>\n<h3>\u8bf7\u6ce8\u610f\u4ee5\u4e0b\u4e8b\u9879\uff1a<\/h3>\n<div><img decoding=\"async\" class=\"post-images\" title=\"\" src=\"https:\/\/cdn.silicloud.com\/blog-img\/blog\/img\/657d7c76913a08637a69c752\/17-0.png\" alt=\"image.png\" \/><\/div>\n<h2>\u89e3\u538bZIP\u6587\u4ef6\uff1a<\/h2>\n<div><img decoding=\"async\" class=\"post-images\" title=\"\" src=\"https:\/\/cdn.silicloud.com\/blog-img\/blog\/img\/657d7c76913a08637a69c752\/19-1.png\" alt=\"image.png\" \/><\/div>\n<h2>\u6587\u4ef6\u540d\u79f0<\/h2>\n<div><img decoding=\"async\" class=\"post-images\" title=\"\" src=\"https:\/\/cdn.silicloud.com\/blog-img\/blog\/img\/657d7c76913a08637a69c752\/21-0.png\" alt=\"image.png\" \/><\/div>\n<h2>\u51c6\u5907\u53d1\u9001\u6d88\u606f\u5230 Kafka \u4e3b\u9898<\/h2>\n<div><img decoding=\"async\" class=\"post-images\" title=\"\" src=\"https:\/\/cdn.silicloud.com\/blog-img\/blog\/img\/657d7c76913a08637a69c752\/23-0.png\" alt=\"image.png\" \/><\/div>\n<h2>\u7ed9 Kafka \u53d1\u9001\u4e00\u6761\u6d88\u606f<\/h2>\n<div><img decoding=\"async\" class=\"post-images\" title=\"\" src=\"https:\/\/cdn.silicloud.com\/blog-img\/blog\/img\/657d7c76913a08637a69c752\/25-0.png\" alt=\"image.png\" \/><\/div>\n<h2>\u6a21\u677fXML<\/h2>\n<pre class=\"post-pre\"><code><span class=\"cp\">&lt;?xml version=\"1.0\" ?&gt;<\/span>\r\n<span class=\"nt\">&lt;template<\/span> <span class=\"na\">encoding-version=<\/span><span class=\"s\">\"1.1\"<\/span><span class=\"nt\">&gt;<\/span>\r\n  <span class=\"nt\">&lt;description&gt;<\/span>This tutorial workflow gets CSV data from the GroupLens website and\r\nuses the PublishKafkaRecord processor to:\r\n-Convert the data into JSON\r\n-Publish the JSON data to the Kafka topic \"Movies\"<span class=\"nt\">&lt;\/description&gt;<\/span>\r\n  <span class=\"nt\">&lt;groupId&gt;<\/span>855d9cd4-015d-1000-8dc5-71f1f96a4779<span class=\"nt\">&lt;\/groupId&gt;<\/span>\r\n  <span class=\"nt\">&lt;name&gt;<\/span>PublishKafkaRecord<span class=\"nt\">&lt;\/name&gt;<\/span>\r\n  <span class=\"nt\">&lt;snippet&gt;<\/span>\r\n    <span class=\"nt\">&lt;connections&gt;<\/span>\r\n      <span class=\"nt\">&lt;id&gt;<\/span>a21d3e99-68e1-3542-0000-000000000000<span class=\"nt\">&lt;\/id&gt;<\/span>\r\n      <span class=\"nt\">&lt;parentGroupId&gt;<\/span>451a635e-0803-3845-0000-000000000000<span class=\"nt\">&lt;\/parentGroupId&gt;<\/span>\r\n      <span class=\"nt\">&lt;backPressureDataSizeThreshold&gt;<\/span>1 GB<span class=\"nt\">&lt;\/backPressureDataSizeThreshold&gt;<\/span>\r\n      <span class=\"nt\">&lt;backPressureObjectThreshold&gt;<\/span>10000<span class=\"nt\">&lt;\/backPressureObjectThreshold&gt;<\/span>\r\n      <span class=\"nt\">&lt;destination&gt;<\/span>\r\n        <span class=\"nt\">&lt;groupId&gt;<\/span>451a635e-0803-3845-0000-000000000000<span class=\"nt\">&lt;\/groupId&gt;<\/span>\r\n        <span class=\"nt\">&lt;id&gt;<\/span>3f560dd9-2a0c-3090-0000-000000000000<span class=\"nt\">&lt;\/id&gt;<\/span>\r\n        <span class=\"nt\">&lt;type&gt;<\/span>PROCESSOR<span class=\"nt\">&lt;\/type&gt;<\/span>\r\n      <span class=\"nt\">&lt;\/destination&gt;<\/span>\r\n      <span class=\"nt\">&lt;flowFileExpiration&gt;<\/span>0 sec<span class=\"nt\">&lt;\/flowFileExpiration&gt;<\/span>\r\n      <span class=\"nt\">&lt;labelIndex&gt;<\/span>1<span class=\"nt\">&lt;\/labelIndex&gt;<\/span>\r\n      <span class=\"nt\">&lt;name&gt;&lt;\/name&gt;<\/span>\r\n      <span class=\"nt\">&lt;selectedRelationships&gt;<\/span>success<span class=\"nt\">&lt;\/selectedRelationships&gt;<\/span>\r\n      <span class=\"nt\">&lt;source&gt;<\/span>\r\n        <span class=\"nt\">&lt;groupId&gt;<\/span>451a635e-0803-3845-0000-000000000000<span class=\"nt\">&lt;\/groupId&gt;<\/span>\r\n        <span class=\"nt\">&lt;id&gt;<\/span>feca53d8-7bfb-38bd-0000-000000000000<span class=\"nt\">&lt;\/id&gt;<\/span>\r\n        <span class=\"nt\">&lt;type&gt;<\/span>PROCESSOR<span class=\"nt\">&lt;\/type&gt;<\/span>\r\n      <span class=\"nt\">&lt;\/source&gt;<\/span>\r\n      <span class=\"nt\">&lt;zIndex&gt;<\/span>0<span class=\"nt\">&lt;\/zIndex&gt;<\/span>\r\n    <span class=\"nt\">&lt;\/connections&gt;<\/span>\r\n    <span class=\"nt\">&lt;connections&gt;<\/span>\r\n      <span class=\"nt\">&lt;id&gt;<\/span>af5788a5-23eb-3d39-0000-000000000000<span class=\"nt\">&lt;\/id&gt;<\/span>\r\n      <span class=\"nt\">&lt;parentGroupId&gt;<\/span>451a635e-0803-3845-0000-000000000000<span class=\"nt\">&lt;\/parentGroupId&gt;<\/span>\r\n      <span class=\"nt\">&lt;backPressureDataSizeThreshold&gt;<\/span>1 GB<span class=\"nt\">&lt;\/backPressureDataSizeThreshold&gt;<\/span>\r\n      <span class=\"nt\">&lt;backPressureObjectThreshold&gt;<\/span>10000<span class=\"nt\">&lt;\/backPressureObjectThreshold&gt;<\/span>\r\n      <span class=\"nt\">&lt;bends&gt;<\/span>\r\n        <span class=\"nt\">&lt;x&gt;<\/span>1043.3389261227253<span class=\"nt\">&lt;\/x&gt;<\/span>\r\n        <span class=\"nt\">&lt;y&gt;<\/span>685.9336127468443<span class=\"nt\">&lt;\/y&gt;<\/span>\r\n      <span class=\"nt\">&lt;\/bends&gt;<\/span>\r\n      <span class=\"nt\">&lt;bends&gt;<\/span>\r\n        <span class=\"nt\">&lt;x&gt;<\/span>1043.3389261227253<span class=\"nt\">&lt;\/x&gt;<\/span>\r\n        <span class=\"nt\">&lt;y&gt;<\/span>735.9336127468443<span class=\"nt\">&lt;\/y&gt;<\/span>\r\n      <span class=\"nt\">&lt;\/bends&gt;<\/span>\r\n      <span class=\"nt\">&lt;destination&gt;<\/span>\r\n        <span class=\"nt\">&lt;groupId&gt;<\/span>451a635e-0803-3845-0000-000000000000<span class=\"nt\">&lt;\/groupId&gt;<\/span>\r\n        <span class=\"nt\">&lt;id&gt;<\/span>3f560dd9-2a0c-3090-0000-000000000000<span class=\"nt\">&lt;\/id&gt;<\/span>\r\n        <span class=\"nt\">&lt;type&gt;<\/span>PROCESSOR<span class=\"nt\">&lt;\/type&gt;<\/span>\r\n      <span class=\"nt\">&lt;\/destination&gt;<\/span>\r\n      <span class=\"nt\">&lt;flowFileExpiration&gt;<\/span>0 sec<span class=\"nt\">&lt;\/flowFileExpiration&gt;<\/span>\r\n      <span class=\"nt\">&lt;labelIndex&gt;<\/span>1<span class=\"nt\">&lt;\/labelIndex&gt;<\/span>\r\n      <span class=\"nt\">&lt;name&gt;&lt;\/name&gt;<\/span>\r\n      <span class=\"nt\">&lt;selectedRelationships&gt;<\/span>failure<span class=\"nt\">&lt;\/selectedRelationships&gt;<\/span>\r\n      <span class=\"nt\">&lt;source&gt;<\/span>\r\n        <span class=\"nt\">&lt;groupId&gt;<\/span>451a635e-0803-3845-0000-000000000000<span class=\"nt\">&lt;\/groupId&gt;<\/span>\r\n        <span class=\"nt\">&lt;id&gt;<\/span>3f560dd9-2a0c-3090-0000-000000000000<span class=\"nt\">&lt;\/id&gt;<\/span>\r\n        <span class=\"nt\">&lt;type&gt;<\/span>PROCESSOR<span class=\"nt\">&lt;\/type&gt;<\/span>\r\n      <span class=\"nt\">&lt;\/source&gt;<\/span>\r\n      <span class=\"nt\">&lt;zIndex&gt;<\/span>0<span class=\"nt\">&lt;\/zIndex&gt;<\/span>\r\n    <span class=\"nt\">&lt;\/connections&gt;<\/span>\r\n    <span class=\"nt\">&lt;connections&gt;<\/span>\r\n      <span class=\"nt\">&lt;id&gt;<\/span>bca31e1c-69fc-3691-0000-000000000000<span class=\"nt\">&lt;\/id&gt;<\/span>\r\n      <span class=\"nt\">&lt;parentGroupId&gt;<\/span>451a635e-0803-3845-0000-000000000000<span class=\"nt\">&lt;\/parentGroupId&gt;<\/span>\r\n      <span class=\"nt\">&lt;backPressureDataSizeThreshold&gt;<\/span>1 GB<span class=\"nt\">&lt;\/backPressureDataSizeThreshold&gt;<\/span>\r\n      <span class=\"nt\">&lt;backPressureObjectThreshold&gt;<\/span>10000<span class=\"nt\">&lt;\/backPressureObjectThreshold&gt;<\/span>\r\n      <span class=\"nt\">&lt;destination&gt;<\/span>\r\n        <span class=\"nt\">&lt;groupId&gt;<\/span>451a635e-0803-3845-0000-000000000000<span class=\"nt\">&lt;\/groupId&gt;<\/span>\r\n        <span class=\"nt\">&lt;id&gt;<\/span>f4cb8328-1431-3494-0000-000000000000<span class=\"nt\">&lt;\/id&gt;<\/span>\r\n        <span class=\"nt\">&lt;type&gt;<\/span>PROCESSOR<span class=\"nt\">&lt;\/type&gt;<\/span>\r\n      <span class=\"nt\">&lt;\/destination&gt;<\/span>\r\n      <span class=\"nt\">&lt;flowFileExpiration&gt;<\/span>0 sec<span class=\"nt\">&lt;\/flowFileExpiration&gt;<\/span>\r\n      <span class=\"nt\">&lt;labelIndex&gt;<\/span>1<span class=\"nt\">&lt;\/labelIndex&gt;<\/span>\r\n      <span class=\"nt\">&lt;name&gt;&lt;\/name&gt;<\/span>\r\n      <span class=\"nt\">&lt;selectedRelationships&gt;<\/span>success<span class=\"nt\">&lt;\/selectedRelationships&gt;<\/span>\r\n      <span class=\"nt\">&lt;source&gt;<\/span>\r\n        <span class=\"nt\">&lt;groupId&gt;<\/span>451a635e-0803-3845-0000-000000000000<span class=\"nt\">&lt;\/groupId&gt;<\/span>\r\n        <span class=\"nt\">&lt;id&gt;<\/span>4004c547-2a1a-321b-0000-000000000000<span class=\"nt\">&lt;\/id&gt;<\/span>\r\n        <span class=\"nt\">&lt;type&gt;<\/span>PROCESSOR<span class=\"nt\">&lt;\/type&gt;<\/span>\r\n      <span class=\"nt\">&lt;\/source&gt;<\/span>\r\n      <span class=\"nt\">&lt;zIndex&gt;<\/span>0<span class=\"nt\">&lt;\/zIndex&gt;<\/span>\r\n    <span class=\"nt\">&lt;\/connections&gt;<\/span>\r\n    <span class=\"nt\">&lt;connections&gt;<\/span>\r\n      <span class=\"nt\">&lt;id&gt;<\/span>edd5e36a-f6d3-3dfb-0000-000000000000<span class=\"nt\">&lt;\/id&gt;<\/span>\r\n      <span class=\"nt\">&lt;parentGroupId&gt;<\/span>451a635e-0803-3845-0000-000000000000<span class=\"nt\">&lt;\/parentGroupId&gt;<\/span>\r\n      <span class=\"nt\">&lt;backPressureDataSizeThreshold&gt;<\/span>1 GB<span class=\"nt\">&lt;\/backPressureDataSizeThreshold&gt;<\/span>\r\n      <span class=\"nt\">&lt;backPressureObjectThreshold&gt;<\/span>10000<span class=\"nt\">&lt;\/backPressureObjectThreshold&gt;<\/span>\r\n      <span class=\"nt\">&lt;destination&gt;<\/span>\r\n        <span class=\"nt\">&lt;groupId&gt;<\/span>451a635e-0803-3845-0000-000000000000<span class=\"nt\">&lt;\/groupId&gt;<\/span>\r\n        <span class=\"nt\">&lt;id&gt;<\/span>c4612b5a-0fe7-367b-0000-000000000000<span class=\"nt\">&lt;\/id&gt;<\/span>\r\n        <span class=\"nt\">&lt;type&gt;<\/span>PROCESSOR<span class=\"nt\">&lt;\/type&gt;<\/span>\r\n      <span class=\"nt\">&lt;\/destination&gt;<\/span>\r\n      <span class=\"nt\">&lt;flowFileExpiration&gt;<\/span>0 sec<span class=\"nt\">&lt;\/flowFileExpiration&gt;<\/span>\r\n      <span class=\"nt\">&lt;labelIndex&gt;<\/span>1<span class=\"nt\">&lt;\/labelIndex&gt;<\/span>\r\n      <span class=\"nt\">&lt;name&gt;&lt;\/name&gt;<\/span>\r\n      <span class=\"nt\">&lt;selectedRelationships&gt;<\/span>success<span class=\"nt\">&lt;\/selectedRelationships&gt;<\/span>\r\n      <span class=\"nt\">&lt;source&gt;<\/span>\r\n        <span class=\"nt\">&lt;groupId&gt;<\/span>451a635e-0803-3845-0000-000000000000<span class=\"nt\">&lt;\/groupId&gt;<\/span>\r\n        <span class=\"nt\">&lt;id&gt;<\/span>f4cb8328-1431-3494-0000-000000000000<span class=\"nt\">&lt;\/id&gt;<\/span>\r\n        <span class=\"nt\">&lt;type&gt;<\/span>PROCESSOR<span class=\"nt\">&lt;\/type&gt;<\/span>\r\n      <span class=\"nt\">&lt;\/source&gt;<\/span>\r\n      <span class=\"nt\">&lt;zIndex&gt;<\/span>0<span class=\"nt\">&lt;\/zIndex&gt;<\/span>\r\n    <span class=\"nt\">&lt;\/connections&gt;<\/span>\r\n    <span class=\"nt\">&lt;connections&gt;<\/span>\r\n      <span class=\"nt\">&lt;id&gt;<\/span>f100ccb4-13c6-3e5c-0000-000000000000<span class=\"nt\">&lt;\/id&gt;<\/span>\r\n      <span class=\"nt\">&lt;parentGroupId&gt;<\/span>451a635e-0803-3845-0000-000000000000<span class=\"nt\">&lt;\/parentGroupId&gt;<\/span>\r\n      <span class=\"nt\">&lt;backPressureDataSizeThreshold&gt;<\/span>1 GB<span class=\"nt\">&lt;\/backPressureDataSizeThreshold&gt;<\/span>\r\n      <span class=\"nt\">&lt;backPressureObjectThreshold&gt;<\/span>10000<span class=\"nt\">&lt;\/backPressureObjectThreshold&gt;<\/span>\r\n      <span class=\"nt\">&lt;destination&gt;<\/span>\r\n        <span class=\"nt\">&lt;groupId&gt;<\/span>451a635e-0803-3845-0000-000000000000<span class=\"nt\">&lt;\/groupId&gt;<\/span>\r\n        <span class=\"nt\">&lt;id&gt;<\/span>feca53d8-7bfb-38bd-0000-000000000000<span class=\"nt\">&lt;\/id&gt;<\/span>\r\n        <span class=\"nt\">&lt;type&gt;<\/span>PROCESSOR<span class=\"nt\">&lt;\/type&gt;<\/span>\r\n      <span class=\"nt\">&lt;\/destination&gt;<\/span>\r\n      <span class=\"nt\">&lt;flowFileExpiration&gt;<\/span>0 sec<span class=\"nt\">&lt;\/flowFileExpiration&gt;<\/span>\r\n      <span class=\"nt\">&lt;labelIndex&gt;<\/span>1<span class=\"nt\">&lt;\/labelIndex&gt;<\/span>\r\n      <span class=\"nt\">&lt;name&gt;&lt;\/name&gt;<\/span>\r\n      <span class=\"nt\">&lt;selectedRelationships&gt;<\/span>movies<span class=\"nt\">&lt;\/selectedRelationships&gt;<\/span>\r\n      <span class=\"nt\">&lt;source&gt;<\/span>\r\n        <span class=\"nt\">&lt;groupId&gt;<\/span>451a635e-0803-3845-0000-000000000000<span class=\"nt\">&lt;\/groupId&gt;<\/span>\r\n        <span class=\"nt\">&lt;id&gt;<\/span>c4612b5a-0fe7-367b-0000-000000000000<span class=\"nt\">&lt;\/id&gt;<\/span>\r\n        <span class=\"nt\">&lt;type&gt;<\/span>PROCESSOR<span class=\"nt\">&lt;\/type&gt;<\/span>\r\n      <span class=\"nt\">&lt;\/source&gt;<\/span>\r\n      <span class=\"nt\">&lt;zIndex&gt;<\/span>0<span class=\"nt\">&lt;\/zIndex&gt;<\/span>\r\n    <span class=\"nt\">&lt;\/connections&gt;<\/span>\r\n    <span class=\"nt\">&lt;controllerServices&gt;<\/span>\r\n      <span class=\"nt\">&lt;id&gt;<\/span>b8531252-2a7c-3648-0000-000000000000<span class=\"nt\">&lt;\/id&gt;<\/span>\r\n      <span class=\"nt\">&lt;parentGroupId&gt;<\/span>451a635e-0803-3845-0000-000000000000<span class=\"nt\">&lt;\/parentGroupId&gt;<\/span>\r\n      <span class=\"nt\">&lt;bundle&gt;<\/span>\r\n        <span class=\"nt\">&lt;artifact&gt;<\/span>nifi-record-serialization-services-nar<span class=\"nt\">&lt;\/artifact&gt;<\/span>\r\n        <span class=\"nt\">&lt;group&gt;<\/span>org.apache.nifi<span class=\"nt\">&lt;\/group&gt;<\/span>\r\n        <span class=\"nt\">&lt;version&gt;<\/span>1.3.0<span class=\"nt\">&lt;\/version&gt;<\/span>\r\n      <span class=\"nt\">&lt;\/bundle&gt;<\/span>\r\n      <span class=\"nt\">&lt;comments&gt;&lt;\/comments&gt;<\/span>\r\n      <span class=\"nt\">&lt;descriptors&gt;<\/span>\r\n        <span class=\"nt\">&lt;entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;key&gt;<\/span>schema-access-strategy<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n          <span class=\"nt\">&lt;value&gt;<\/span>\r\n            <span class=\"nt\">&lt;name&gt;<\/span>schema-access-strategy<span class=\"nt\">&lt;\/name&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/value&gt;<\/span>\r\n        <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n        <span class=\"nt\">&lt;entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;key&gt;<\/span>schema-registry<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n          <span class=\"nt\">&lt;value&gt;<\/span>\r\n            <span class=\"nt\">&lt;identifiesControllerService&gt;<\/span>org.apache.nifi.schemaregistry.services.SchemaRegistry<span class=\"nt\">&lt;\/identifiesControllerService&gt;<\/span>\r\n            <span class=\"nt\">&lt;name&gt;<\/span>schema-registry<span class=\"nt\">&lt;\/name&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/value&gt;<\/span>\r\n        <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n        <span class=\"nt\">&lt;entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;key&gt;<\/span>schema-name<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n          <span class=\"nt\">&lt;value&gt;<\/span>\r\n            <span class=\"nt\">&lt;name&gt;<\/span>schema-name<span class=\"nt\">&lt;\/name&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/value&gt;<\/span>\r\n        <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n        <span class=\"nt\">&lt;entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;key&gt;<\/span>schema-text<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n          <span class=\"nt\">&lt;value&gt;<\/span>\r\n            <span class=\"nt\">&lt;name&gt;<\/span>schema-text<span class=\"nt\">&lt;\/name&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/value&gt;<\/span>\r\n        <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n        <span class=\"nt\">&lt;entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;key&gt;<\/span>Date Format<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n          <span class=\"nt\">&lt;value&gt;<\/span>\r\n            <span class=\"nt\">&lt;name&gt;<\/span>Date Format<span class=\"nt\">&lt;\/name&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/value&gt;<\/span>\r\n        <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n        <span class=\"nt\">&lt;entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;key&gt;<\/span>Time Format<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n          <span class=\"nt\">&lt;value&gt;<\/span>\r\n            <span class=\"nt\">&lt;name&gt;<\/span>Time Format<span class=\"nt\">&lt;\/name&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/value&gt;<\/span>\r\n        <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n        <span class=\"nt\">&lt;entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;key&gt;<\/span>Timestamp Format<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n          <span class=\"nt\">&lt;value&gt;<\/span>\r\n            <span class=\"nt\">&lt;name&gt;<\/span>Timestamp Format<span class=\"nt\">&lt;\/name&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/value&gt;<\/span>\r\n        <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n        <span class=\"nt\">&lt;entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;key&gt;<\/span>CSV Format<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n          <span class=\"nt\">&lt;value&gt;<\/span>\r\n            <span class=\"nt\">&lt;name&gt;<\/span>CSV Format<span class=\"nt\">&lt;\/name&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/value&gt;<\/span>\r\n        <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n        <span class=\"nt\">&lt;entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;key&gt;<\/span>Value Separator<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n          <span class=\"nt\">&lt;value&gt;<\/span>\r\n            <span class=\"nt\">&lt;name&gt;<\/span>Value Separator<span class=\"nt\">&lt;\/name&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/value&gt;<\/span>\r\n        <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n        <span class=\"nt\">&lt;entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;key&gt;<\/span>Skip Header Line<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n          <span class=\"nt\">&lt;value&gt;<\/span>\r\n            <span class=\"nt\">&lt;name&gt;<\/span>Skip Header Line<span class=\"nt\">&lt;\/name&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/value&gt;<\/span>\r\n        <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n        <span class=\"nt\">&lt;entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;key&gt;<\/span>Quote Character<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n          <span class=\"nt\">&lt;value&gt;<\/span>\r\n            <span class=\"nt\">&lt;name&gt;<\/span>Quote Character<span class=\"nt\">&lt;\/name&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/value&gt;<\/span>\r\n        <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n        <span class=\"nt\">&lt;entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;key&gt;<\/span>Escape Character<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n          <span class=\"nt\">&lt;value&gt;<\/span>\r\n            <span class=\"nt\">&lt;name&gt;<\/span>Escape Character<span class=\"nt\">&lt;\/name&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/value&gt;<\/span>\r\n        <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n        <span class=\"nt\">&lt;entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;key&gt;<\/span>Comment Marker<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n          <span class=\"nt\">&lt;value&gt;<\/span>\r\n            <span class=\"nt\">&lt;name&gt;<\/span>Comment Marker<span class=\"nt\">&lt;\/name&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/value&gt;<\/span>\r\n        <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n        <span class=\"nt\">&lt;entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;key&gt;<\/span>Null String<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n          <span class=\"nt\">&lt;value&gt;<\/span>\r\n            <span class=\"nt\">&lt;name&gt;<\/span>Null String<span class=\"nt\">&lt;\/name&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/value&gt;<\/span>\r\n        <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n        <span class=\"nt\">&lt;entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;key&gt;<\/span>Trim Fields<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n          <span class=\"nt\">&lt;value&gt;<\/span>\r\n            <span class=\"nt\">&lt;name&gt;<\/span>Trim Fields<span class=\"nt\">&lt;\/name&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/value&gt;<\/span>\r\n        <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n      <span class=\"nt\">&lt;\/descriptors&gt;<\/span>\r\n      <span class=\"nt\">&lt;name&gt;<\/span>CSVReader<span class=\"nt\">&lt;\/name&gt;<\/span>\r\n      <span class=\"nt\">&lt;persistsState&gt;<\/span>false<span class=\"nt\">&lt;\/persistsState&gt;<\/span>\r\n      <span class=\"nt\">&lt;properties&gt;<\/span>\r\n        <span class=\"nt\">&lt;entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;key&gt;<\/span>schema-access-strategy<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n          <span class=\"nt\">&lt;value&gt;<\/span>schema-name<span class=\"nt\">&lt;\/value&gt;<\/span>\r\n        <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n        <span class=\"nt\">&lt;entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;key&gt;<\/span>schema-registry<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n          <span class=\"nt\">&lt;value&gt;<\/span>bdeb04f8-7ece-385c-0000-000000000000<span class=\"nt\">&lt;\/value&gt;<\/span>\r\n        <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n        <span class=\"nt\">&lt;entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;key&gt;<\/span>schema-name<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n          <span class=\"nt\">&lt;value&gt;<\/span>${schema.name}<span class=\"nt\">&lt;\/value&gt;<\/span>\r\n        <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n        <span class=\"nt\">&lt;entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;key&gt;<\/span>schema-text<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n          <span class=\"nt\">&lt;value&gt;<\/span>${avro.schema}<span class=\"nt\">&lt;\/value&gt;<\/span>\r\n        <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n        <span class=\"nt\">&lt;entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;key&gt;<\/span>Date Format<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n        <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n        <span class=\"nt\">&lt;entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;key&gt;<\/span>Time Format<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n        <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n        <span class=\"nt\">&lt;entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;key&gt;<\/span>Timestamp Format<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n        <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n        <span class=\"nt\">&lt;entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;key&gt;<\/span>CSV Format<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n          <span class=\"nt\">&lt;value&gt;<\/span>custom<span class=\"nt\">&lt;\/value&gt;<\/span>\r\n        <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n        <span class=\"nt\">&lt;entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;key&gt;<\/span>Value Separator<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n          <span class=\"nt\">&lt;value&gt;<\/span>,<span class=\"nt\">&lt;\/value&gt;<\/span>\r\n        <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n        <span class=\"nt\">&lt;entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;key&gt;<\/span>Skip Header Line<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n          <span class=\"nt\">&lt;value&gt;<\/span>true<span class=\"nt\">&lt;\/value&gt;<\/span>\r\n        <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n        <span class=\"nt\">&lt;entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;key&gt;<\/span>Quote Character<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n          <span class=\"nt\">&lt;value&gt;<\/span>\"<span class=\"nt\">&lt;\/value&gt;<\/span>\r\n        <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n        <span class=\"nt\">&lt;entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;key&gt;<\/span>Escape Character<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n          <span class=\"nt\">&lt;value&gt;<\/span>\\<span class=\"nt\">&lt;\/value&gt;<\/span>\r\n        <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n        <span class=\"nt\">&lt;entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;key&gt;<\/span>Comment Marker<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n        <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n        <span class=\"nt\">&lt;entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;key&gt;<\/span>Null String<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n        <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n        <span class=\"nt\">&lt;entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;key&gt;<\/span>Trim Fields<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n          <span class=\"nt\">&lt;value&gt;<\/span>true<span class=\"nt\">&lt;\/value&gt;<\/span>\r\n        <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n      <span class=\"nt\">&lt;\/properties&gt;<\/span>\r\n      <span class=\"nt\">&lt;state&gt;<\/span>ENABLED<span class=\"nt\">&lt;\/state&gt;<\/span>\r\n      <span class=\"nt\">&lt;type&gt;<\/span>org.apache.nifi.csv.CSVReader<span class=\"nt\">&lt;\/type&gt;<\/span>\r\n    <span class=\"nt\">&lt;\/controllerServices&gt;<\/span>\r\n    <span class=\"nt\">&lt;controllerServices&gt;<\/span>\r\n      <span class=\"nt\">&lt;id&gt;<\/span>bdeb04f8-7ece-385c-0000-000000000000<span class=\"nt\">&lt;\/id&gt;<\/span>\r\n      <span class=\"nt\">&lt;parentGroupId&gt;<\/span>451a635e-0803-3845-0000-000000000000<span class=\"nt\">&lt;\/parentGroupId&gt;<\/span>\r\n      <span class=\"nt\">&lt;bundle&gt;<\/span>\r\n        <span class=\"nt\">&lt;artifact&gt;<\/span>nifi-registry-nar<span class=\"nt\">&lt;\/artifact&gt;<\/span>\r\n        <span class=\"nt\">&lt;group&gt;<\/span>org.apache.nifi<span class=\"nt\">&lt;\/group&gt;<\/span>\r\n        <span class=\"nt\">&lt;version&gt;<\/span>1.3.0<span class=\"nt\">&lt;\/version&gt;<\/span>\r\n      <span class=\"nt\">&lt;\/bundle&gt;<\/span>\r\n      <span class=\"nt\">&lt;comments&gt;&lt;\/comments&gt;<\/span>\r\n      <span class=\"nt\">&lt;descriptors&gt;<\/span>\r\n        <span class=\"nt\">&lt;entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;key&gt;<\/span>movies<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n          <span class=\"nt\">&lt;value&gt;<\/span>\r\n            <span class=\"nt\">&lt;name&gt;<\/span>movies<span class=\"nt\">&lt;\/name&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/value&gt;<\/span>\r\n        <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n      <span class=\"nt\">&lt;\/descriptors&gt;<\/span>\r\n      <span class=\"nt\">&lt;name&gt;<\/span>AvroSchemaRegistry<span class=\"nt\">&lt;\/name&gt;<\/span>\r\n      <span class=\"nt\">&lt;persistsState&gt;<\/span>false<span class=\"nt\">&lt;\/persistsState&gt;<\/span>\r\n      <span class=\"nt\">&lt;properties&gt;<\/span>\r\n        <span class=\"nt\">&lt;entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;key&gt;<\/span>movies<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n          <span class=\"nt\">&lt;value&gt;<\/span>{\r\n  \"type\": \"record\",\r\n  \"name\": \"MoviesRecord\",\r\n  \"fields\" : [\r\n    {\"name\": \"movieId\", \"type\": \"long\"},\r\n    {\"name\": \"title\", \"type\": [\"null\", \"string\"]},\r\n    {\"name\": \"genres\", \"type\": [\"null\", \"string\"]}\r\n  ]\r\n}<span class=\"nt\">&lt;\/value&gt;<\/span>\r\n        <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n      <span class=\"nt\">&lt;\/properties&gt;<\/span>\r\n      <span class=\"nt\">&lt;state&gt;<\/span>ENABLED<span class=\"nt\">&lt;\/state&gt;<\/span>\r\n      <span class=\"nt\">&lt;type&gt;<\/span>org.apache.nifi.schemaregistry.services.AvroSchemaRegistry<span class=\"nt\">&lt;\/type&gt;<\/span>\r\n    <span class=\"nt\">&lt;\/controllerServices&gt;<\/span>\r\n    <span class=\"nt\">&lt;controllerServices&gt;<\/span>\r\n      <span class=\"nt\">&lt;id&gt;<\/span>290d56c9-1e35-3dba-0000-000000000000<span class=\"nt\">&lt;\/id&gt;<\/span>\r\n      <span class=\"nt\">&lt;parentGroupId&gt;<\/span>451a635e-0803-3845-0000-000000000000<span class=\"nt\">&lt;\/parentGroupId&gt;<\/span>\r\n      <span class=\"nt\">&lt;bundle&gt;<\/span>\r\n        <span class=\"nt\">&lt;artifact&gt;<\/span>nifi-record-serialization-services-nar<span class=\"nt\">&lt;\/artifact&gt;<\/span>\r\n        <span class=\"nt\">&lt;group&gt;<\/span>org.apache.nifi<span class=\"nt\">&lt;\/group&gt;<\/span>\r\n        <span class=\"nt\">&lt;version&gt;<\/span>1.3.0<span class=\"nt\">&lt;\/version&gt;<\/span>\r\n      <span class=\"nt\">&lt;\/bundle&gt;<\/span>\r\n      <span class=\"nt\">&lt;comments&gt;&lt;\/comments&gt;<\/span>\r\n      <span class=\"nt\">&lt;descriptors&gt;<\/span>\r\n        <span class=\"nt\">&lt;entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;key&gt;<\/span>Schema Write Strategy<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n          <span class=\"nt\">&lt;value&gt;<\/span>\r\n            <span class=\"nt\">&lt;name&gt;<\/span>Schema Write Strategy<span class=\"nt\">&lt;\/name&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/value&gt;<\/span>\r\n        <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n        <span class=\"nt\">&lt;entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;key&gt;<\/span>schema-access-strategy<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n          <span class=\"nt\">&lt;value&gt;<\/span>\r\n            <span class=\"nt\">&lt;name&gt;<\/span>schema-access-strategy<span class=\"nt\">&lt;\/name&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/value&gt;<\/span>\r\n        <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n        <span class=\"nt\">&lt;entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;key&gt;<\/span>schema-registry<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n          <span class=\"nt\">&lt;value&gt;<\/span>\r\n            <span class=\"nt\">&lt;identifiesControllerService&gt;<\/span>org.apache.nifi.schemaregistry.services.SchemaRegistry<span class=\"nt\">&lt;\/identifiesControllerService&gt;<\/span>\r\n            <span class=\"nt\">&lt;name&gt;<\/span>schema-registry<span class=\"nt\">&lt;\/name&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/value&gt;<\/span>\r\n        <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n        <span class=\"nt\">&lt;entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;key&gt;<\/span>schema-name<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n          <span class=\"nt\">&lt;value&gt;<\/span>\r\n            <span class=\"nt\">&lt;name&gt;<\/span>schema-name<span class=\"nt\">&lt;\/name&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/value&gt;<\/span>\r\n        <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n        <span class=\"nt\">&lt;entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;key&gt;<\/span>schema-text<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n          <span class=\"nt\">&lt;value&gt;<\/span>\r\n            <span class=\"nt\">&lt;name&gt;<\/span>schema-text<span class=\"nt\">&lt;\/name&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/value&gt;<\/span>\r\n        <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n        <span class=\"nt\">&lt;entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;key&gt;<\/span>Date Format<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n          <span class=\"nt\">&lt;value&gt;<\/span>\r\n            <span class=\"nt\">&lt;name&gt;<\/span>Date Format<span class=\"nt\">&lt;\/name&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/value&gt;<\/span>\r\n        <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n        <span class=\"nt\">&lt;entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;key&gt;<\/span>Time Format<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n          <span class=\"nt\">&lt;value&gt;<\/span>\r\n            <span class=\"nt\">&lt;name&gt;<\/span>Time Format<span class=\"nt\">&lt;\/name&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/value&gt;<\/span>\r\n        <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n        <span class=\"nt\">&lt;entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;key&gt;<\/span>Timestamp Format<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n          <span class=\"nt\">&lt;value&gt;<\/span>\r\n            <span class=\"nt\">&lt;name&gt;<\/span>Timestamp Format<span class=\"nt\">&lt;\/name&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/value&gt;<\/span>\r\n        <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n        <span class=\"nt\">&lt;entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;key&gt;<\/span>Pretty Print JSON<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n          <span class=\"nt\">&lt;value&gt;<\/span>\r\n            <span class=\"nt\">&lt;name&gt;<\/span>Pretty Print JSON<span class=\"nt\">&lt;\/name&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/value&gt;<\/span>\r\n        <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n      <span class=\"nt\">&lt;\/descriptors&gt;<\/span>\r\n      <span class=\"nt\">&lt;name&gt;<\/span>JsonRecordSetWriter<span class=\"nt\">&lt;\/name&gt;<\/span>\r\n      <span class=\"nt\">&lt;persistsState&gt;<\/span>false<span class=\"nt\">&lt;\/persistsState&gt;<\/span>\r\n      <span class=\"nt\">&lt;properties&gt;<\/span>\r\n        <span class=\"nt\">&lt;entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;key&gt;<\/span>Schema Write Strategy<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n          <span class=\"nt\">&lt;value&gt;<\/span>schema-name<span class=\"nt\">&lt;\/value&gt;<\/span>\r\n        <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n        <span class=\"nt\">&lt;entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;key&gt;<\/span>schema-access-strategy<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n          <span class=\"nt\">&lt;value&gt;<\/span>schema-name<span class=\"nt\">&lt;\/value&gt;<\/span>\r\n        <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n        <span class=\"nt\">&lt;entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;key&gt;<\/span>schema-registry<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n          <span class=\"nt\">&lt;value&gt;<\/span>bdeb04f8-7ece-385c-0000-000000000000<span class=\"nt\">&lt;\/value&gt;<\/span>\r\n        <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n        <span class=\"nt\">&lt;entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;key&gt;<\/span>schema-name<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n          <span class=\"nt\">&lt;value&gt;<\/span>${schema.name}<span class=\"nt\">&lt;\/value&gt;<\/span>\r\n        <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n        <span class=\"nt\">&lt;entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;key&gt;<\/span>schema-text<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n          <span class=\"nt\">&lt;value&gt;<\/span>${avro.schema}<span class=\"nt\">&lt;\/value&gt;<\/span>\r\n        <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n        <span class=\"nt\">&lt;entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;key&gt;<\/span>Date Format<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n        <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n        <span class=\"nt\">&lt;entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;key&gt;<\/span>Time Format<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n        <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n        <span class=\"nt\">&lt;entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;key&gt;<\/span>Timestamp Format<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n        <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n        <span class=\"nt\">&lt;entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;key&gt;<\/span>Pretty Print JSON<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n          <span class=\"nt\">&lt;value&gt;<\/span>false<span class=\"nt\">&lt;\/value&gt;<\/span>\r\n        <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n      <span class=\"nt\">&lt;\/properties&gt;<\/span>\r\n      <span class=\"nt\">&lt;state&gt;<\/span>ENABLED<span class=\"nt\">&lt;\/state&gt;<\/span>\r\n      <span class=\"nt\">&lt;type&gt;<\/span>org.apache.nifi.json.JsonRecordSetWriter<span class=\"nt\">&lt;\/type&gt;<\/span>\r\n    <span class=\"nt\">&lt;\/controllerServices&gt;<\/span>\r\n    <span class=\"nt\">&lt;processors&gt;<\/span>\r\n      <span class=\"nt\">&lt;id&gt;<\/span>c4612b5a-0fe7-367b-0000-000000000000<span class=\"nt\">&lt;\/id&gt;<\/span>\r\n      <span class=\"nt\">&lt;parentGroupId&gt;<\/span>451a635e-0803-3845-0000-000000000000<span class=\"nt\">&lt;\/parentGroupId&gt;<\/span>\r\n      <span class=\"nt\">&lt;position&gt;<\/span>\r\n        <span class=\"nt\">&lt;x&gt;<\/span>0.0<span class=\"nt\">&lt;\/x&gt;<\/span>\r\n        <span class=\"nt\">&lt;y&gt;<\/span>441.2567407123754<span class=\"nt\">&lt;\/y&gt;<\/span>\r\n      <span class=\"nt\">&lt;\/position&gt;<\/span>\r\n      <span class=\"nt\">&lt;bundle&gt;<\/span>\r\n        <span class=\"nt\">&lt;artifact&gt;<\/span>nifi-standard-nar<span class=\"nt\">&lt;\/artifact&gt;<\/span>\r\n        <span class=\"nt\">&lt;group&gt;<\/span>org.apache.nifi<span class=\"nt\">&lt;\/group&gt;<\/span>\r\n        <span class=\"nt\">&lt;version&gt;<\/span>1.3.0<span class=\"nt\">&lt;\/version&gt;<\/span>\r\n      <span class=\"nt\">&lt;\/bundle&gt;<\/span>\r\n      <span class=\"nt\">&lt;config&gt;<\/span>\r\n        <span class=\"nt\">&lt;bulletinLevel&gt;<\/span>WARN<span class=\"nt\">&lt;\/bulletinLevel&gt;<\/span>\r\n        <span class=\"nt\">&lt;comments&gt;&lt;\/comments&gt;<\/span>\r\n        <span class=\"nt\">&lt;concurrentlySchedulableTaskCount&gt;<\/span>1<span class=\"nt\">&lt;\/concurrentlySchedulableTaskCount&gt;<\/span>\r\n        <span class=\"nt\">&lt;descriptors&gt;<\/span>\r\n          <span class=\"nt\">&lt;entry&gt;<\/span>\r\n            <span class=\"nt\">&lt;key&gt;<\/span>Routing Strategy<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n            <span class=\"nt\">&lt;value&gt;<\/span>\r\n              <span class=\"nt\">&lt;name&gt;<\/span>Routing Strategy<span class=\"nt\">&lt;\/name&gt;<\/span>\r\n            <span class=\"nt\">&lt;\/value&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;entry&gt;<\/span>\r\n            <span class=\"nt\">&lt;key&gt;<\/span>movies<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n            <span class=\"nt\">&lt;value&gt;<\/span>\r\n              <span class=\"nt\">&lt;name&gt;<\/span>movies<span class=\"nt\">&lt;\/name&gt;<\/span>\r\n            <span class=\"nt\">&lt;\/value&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;entry&gt;<\/span>\r\n            <span class=\"nt\">&lt;key&gt;<\/span>ratings<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n            <span class=\"nt\">&lt;value&gt;<\/span>\r\n              <span class=\"nt\">&lt;name&gt;<\/span>ratings<span class=\"nt\">&lt;\/name&gt;<\/span>\r\n            <span class=\"nt\">&lt;\/value&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;entry&gt;<\/span>\r\n            <span class=\"nt\">&lt;key&gt;<\/span>tags<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n            <span class=\"nt\">&lt;value&gt;<\/span>\r\n              <span class=\"nt\">&lt;name&gt;<\/span>tags<span class=\"nt\">&lt;\/name&gt;<\/span>\r\n            <span class=\"nt\">&lt;\/value&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n        <span class=\"nt\">&lt;\/descriptors&gt;<\/span>\r\n        <span class=\"nt\">&lt;executionNode&gt;<\/span>ALL<span class=\"nt\">&lt;\/executionNode&gt;<\/span>\r\n        <span class=\"nt\">&lt;lossTolerant&gt;<\/span>false<span class=\"nt\">&lt;\/lossTolerant&gt;<\/span>\r\n        <span class=\"nt\">&lt;penaltyDuration&gt;<\/span>30 sec<span class=\"nt\">&lt;\/penaltyDuration&gt;<\/span>\r\n        <span class=\"nt\">&lt;properties&gt;<\/span>\r\n          <span class=\"nt\">&lt;entry&gt;<\/span>\r\n            <span class=\"nt\">&lt;key&gt;<\/span>Routing Strategy<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n            <span class=\"nt\">&lt;value&gt;<\/span>Route to Property name<span class=\"nt\">&lt;\/value&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;entry&gt;<\/span>\r\n            <span class=\"nt\">&lt;key&gt;<\/span>movies<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n            <span class=\"nt\">&lt;value&gt;<\/span>${filename:equals('movies.csv')}<span class=\"nt\">&lt;\/value&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;entry&gt;<\/span>\r\n            <span class=\"nt\">&lt;key&gt;<\/span>ratings<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n            <span class=\"nt\">&lt;value&gt;<\/span>${filename:equals('ratings.csv')}<span class=\"nt\">&lt;\/value&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;entry&gt;<\/span>\r\n            <span class=\"nt\">&lt;key&gt;<\/span>tags<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n            <span class=\"nt\">&lt;value&gt;<\/span>${filename:equals('tags.csv')}<span class=\"nt\">&lt;\/value&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n        <span class=\"nt\">&lt;\/properties&gt;<\/span>\r\n        <span class=\"nt\">&lt;runDurationMillis&gt;<\/span>0<span class=\"nt\">&lt;\/runDurationMillis&gt;<\/span>\r\n        <span class=\"nt\">&lt;schedulingPeriod&gt;<\/span>0 sec<span class=\"nt\">&lt;\/schedulingPeriod&gt;<\/span>\r\n        <span class=\"nt\">&lt;schedulingStrategy&gt;<\/span>TIMER_DRIVEN<span class=\"nt\">&lt;\/schedulingStrategy&gt;<\/span>\r\n        <span class=\"nt\">&lt;yieldDuration&gt;<\/span>1 sec<span class=\"nt\">&lt;\/yieldDuration&gt;<\/span>\r\n      <span class=\"nt\">&lt;\/config&gt;<\/span>\r\n      <span class=\"nt\">&lt;name&gt;<\/span>RouteOnAttribute<span class=\"nt\">&lt;\/name&gt;<\/span>\r\n      <span class=\"nt\">&lt;relationships&gt;<\/span>\r\n        <span class=\"nt\">&lt;autoTerminate&gt;<\/span>false<span class=\"nt\">&lt;\/autoTerminate&gt;<\/span>\r\n        <span class=\"nt\">&lt;name&gt;<\/span>movies<span class=\"nt\">&lt;\/name&gt;<\/span>\r\n      <span class=\"nt\">&lt;\/relationships&gt;<\/span>\r\n      <span class=\"nt\">&lt;relationships&gt;<\/span>\r\n        <span class=\"nt\">&lt;autoTerminate&gt;<\/span>true<span class=\"nt\">&lt;\/autoTerminate&gt;<\/span>\r\n        <span class=\"nt\">&lt;name&gt;<\/span>ratings<span class=\"nt\">&lt;\/name&gt;<\/span>\r\n      <span class=\"nt\">&lt;\/relationships&gt;<\/span>\r\n      <span class=\"nt\">&lt;relationships&gt;<\/span>\r\n        <span class=\"nt\">&lt;autoTerminate&gt;<\/span>true<span class=\"nt\">&lt;\/autoTerminate&gt;<\/span>\r\n        <span class=\"nt\">&lt;name&gt;<\/span>tags<span class=\"nt\">&lt;\/name&gt;<\/span>\r\n      <span class=\"nt\">&lt;\/relationships&gt;<\/span>\r\n      <span class=\"nt\">&lt;relationships&gt;<\/span>\r\n        <span class=\"nt\">&lt;autoTerminate&gt;<\/span>true<span class=\"nt\">&lt;\/autoTerminate&gt;<\/span>\r\n        <span class=\"nt\">&lt;name&gt;<\/span>unmatched<span class=\"nt\">&lt;\/name&gt;<\/span>\r\n      <span class=\"nt\">&lt;\/relationships&gt;<\/span>\r\n      <span class=\"nt\">&lt;style&gt;&lt;\/style&gt;<\/span>\r\n      <span class=\"nt\">&lt;type&gt;<\/span>org.apache.nifi.processors.standard.RouteOnAttribute<span class=\"nt\">&lt;\/type&gt;<\/span>\r\n    <span class=\"nt\">&lt;\/processors&gt;<\/span>\r\n    <span class=\"nt\">&lt;processors&gt;<\/span>\r\n      <span class=\"nt\">&lt;id&gt;<\/span>f4cb8328-1431-3494-0000-000000000000<span class=\"nt\">&lt;\/id&gt;<\/span>\r\n      <span class=\"nt\">&lt;parentGroupId&gt;<\/span>451a635e-0803-3845-0000-000000000000<span class=\"nt\">&lt;\/parentGroupId&gt;<\/span>\r\n      <span class=\"nt\">&lt;position&gt;<\/span>\r\n        <span class=\"nt\">&lt;x&gt;<\/span>0.0<span class=\"nt\">&lt;\/x&gt;<\/span>\r\n        <span class=\"nt\">&lt;y&gt;<\/span>224.95887663044255<span class=\"nt\">&lt;\/y&gt;<\/span>\r\n      <span class=\"nt\">&lt;\/position&gt;<\/span>\r\n      <span class=\"nt\">&lt;bundle&gt;<\/span>\r\n        <span class=\"nt\">&lt;artifact&gt;<\/span>nifi-standard-nar<span class=\"nt\">&lt;\/artifact&gt;<\/span>\r\n        <span class=\"nt\">&lt;group&gt;<\/span>org.apache.nifi<span class=\"nt\">&lt;\/group&gt;<\/span>\r\n        <span class=\"nt\">&lt;version&gt;<\/span>1.3.0<span class=\"nt\">&lt;\/version&gt;<\/span>\r\n      <span class=\"nt\">&lt;\/bundle&gt;<\/span>\r\n      <span class=\"nt\">&lt;config&gt;<\/span>\r\n        <span class=\"nt\">&lt;bulletinLevel&gt;<\/span>WARN<span class=\"nt\">&lt;\/bulletinLevel&gt;<\/span>\r\n        <span class=\"nt\">&lt;comments&gt;&lt;\/comments&gt;<\/span>\r\n        <span class=\"nt\">&lt;concurrentlySchedulableTaskCount&gt;<\/span>1<span class=\"nt\">&lt;\/concurrentlySchedulableTaskCount&gt;<\/span>\r\n        <span class=\"nt\">&lt;descriptors&gt;<\/span>\r\n          <span class=\"nt\">&lt;entry&gt;<\/span>\r\n            <span class=\"nt\">&lt;key&gt;<\/span>Packaging Format<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n            <span class=\"nt\">&lt;value&gt;<\/span>\r\n              <span class=\"nt\">&lt;name&gt;<\/span>Packaging Format<span class=\"nt\">&lt;\/name&gt;<\/span>\r\n            <span class=\"nt\">&lt;\/value&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;entry&gt;<\/span>\r\n            <span class=\"nt\">&lt;key&gt;<\/span>File Filter<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n            <span class=\"nt\">&lt;value&gt;<\/span>\r\n              <span class=\"nt\">&lt;name&gt;<\/span>File Filter<span class=\"nt\">&lt;\/name&gt;<\/span>\r\n            <span class=\"nt\">&lt;\/value&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n        <span class=\"nt\">&lt;\/descriptors&gt;<\/span>\r\n        <span class=\"nt\">&lt;executionNode&gt;<\/span>ALL<span class=\"nt\">&lt;\/executionNode&gt;<\/span>\r\n        <span class=\"nt\">&lt;lossTolerant&gt;<\/span>false<span class=\"nt\">&lt;\/lossTolerant&gt;<\/span>\r\n        <span class=\"nt\">&lt;penaltyDuration&gt;<\/span>30 sec<span class=\"nt\">&lt;\/penaltyDuration&gt;<\/span>\r\n        <span class=\"nt\">&lt;properties&gt;<\/span>\r\n          <span class=\"nt\">&lt;entry&gt;<\/span>\r\n            <span class=\"nt\">&lt;key&gt;<\/span>Packaging Format<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n            <span class=\"nt\">&lt;value&gt;<\/span>zip<span class=\"nt\">&lt;\/value&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;entry&gt;<\/span>\r\n            <span class=\"nt\">&lt;key&gt;<\/span>File Filter<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n            <span class=\"nt\">&lt;value&gt;<\/span>.*<span class=\"nt\">&lt;\/value&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n        <span class=\"nt\">&lt;\/properties&gt;<\/span>\r\n        <span class=\"nt\">&lt;runDurationMillis&gt;<\/span>0<span class=\"nt\">&lt;\/runDurationMillis&gt;<\/span>\r\n        <span class=\"nt\">&lt;schedulingPeriod&gt;<\/span>0 sec<span class=\"nt\">&lt;\/schedulingPeriod&gt;<\/span>\r\n        <span class=\"nt\">&lt;schedulingStrategy&gt;<\/span>TIMER_DRIVEN<span class=\"nt\">&lt;\/schedulingStrategy&gt;<\/span>\r\n        <span class=\"nt\">&lt;yieldDuration&gt;<\/span>1 sec<span class=\"nt\">&lt;\/yieldDuration&gt;<\/span>\r\n      <span class=\"nt\">&lt;\/config&gt;<\/span>\r\n      <span class=\"nt\">&lt;name&gt;<\/span>Unzip<span class=\"nt\">&lt;\/name&gt;<\/span>\r\n      <span class=\"nt\">&lt;relationships&gt;<\/span>\r\n        <span class=\"nt\">&lt;autoTerminate&gt;<\/span>true<span class=\"nt\">&lt;\/autoTerminate&gt;<\/span>\r\n        <span class=\"nt\">&lt;name&gt;<\/span>failure<span class=\"nt\">&lt;\/name&gt;<\/span>\r\n      <span class=\"nt\">&lt;\/relationships&gt;<\/span>\r\n      <span class=\"nt\">&lt;relationships&gt;<\/span>\r\n        <span class=\"nt\">&lt;autoTerminate&gt;<\/span>true<span class=\"nt\">&lt;\/autoTerminate&gt;<\/span>\r\n        <span class=\"nt\">&lt;name&gt;<\/span>original<span class=\"nt\">&lt;\/name&gt;<\/span>\r\n      <span class=\"nt\">&lt;\/relationships&gt;<\/span>\r\n      <span class=\"nt\">&lt;relationships&gt;<\/span>\r\n        <span class=\"nt\">&lt;autoTerminate&gt;<\/span>false<span class=\"nt\">&lt;\/autoTerminate&gt;<\/span>\r\n        <span class=\"nt\">&lt;name&gt;<\/span>success<span class=\"nt\">&lt;\/name&gt;<\/span>\r\n      <span class=\"nt\">&lt;\/relationships&gt;<\/span>\r\n      <span class=\"nt\">&lt;style&gt;&lt;\/style&gt;<\/span>\r\n      <span class=\"nt\">&lt;type&gt;<\/span>org.apache.nifi.processors.standard.UnpackContent<span class=\"nt\">&lt;\/type&gt;<\/span>\r\n    <span class=\"nt\">&lt;\/processors&gt;<\/span>\r\n    <span class=\"nt\">&lt;processors&gt;<\/span>\r\n      <span class=\"nt\">&lt;id&gt;<\/span>feca53d8-7bfb-38bd-0000-000000000000<span class=\"nt\">&lt;\/id&gt;<\/span>\r\n      <span class=\"nt\">&lt;parentGroupId&gt;<\/span>451a635e-0803-3845-0000-000000000000<span class=\"nt\">&lt;\/parentGroupId&gt;<\/span>\r\n      <span class=\"nt\">&lt;position&gt;<\/span>\r\n        <span class=\"nt\">&lt;x&gt;<\/span>0.0<span class=\"nt\">&lt;\/x&gt;<\/span>\r\n        <span class=\"nt\">&lt;y&gt;<\/span>645.9336127468443<span class=\"nt\">&lt;\/y&gt;<\/span>\r\n      <span class=\"nt\">&lt;\/position&gt;<\/span>\r\n      <span class=\"nt\">&lt;bundle&gt;<\/span>\r\n        <span class=\"nt\">&lt;artifact&gt;<\/span>nifi-update-attribute-nar<span class=\"nt\">&lt;\/artifact&gt;<\/span>\r\n        <span class=\"nt\">&lt;group&gt;<\/span>org.apache.nifi<span class=\"nt\">&lt;\/group&gt;<\/span>\r\n        <span class=\"nt\">&lt;version&gt;<\/span>1.3.0<span class=\"nt\">&lt;\/version&gt;<\/span>\r\n      <span class=\"nt\">&lt;\/bundle&gt;<\/span>\r\n      <span class=\"nt\">&lt;config&gt;<\/span>\r\n        <span class=\"nt\">&lt;bulletinLevel&gt;<\/span>WARN<span class=\"nt\">&lt;\/bulletinLevel&gt;<\/span>\r\n        <span class=\"nt\">&lt;comments&gt;&lt;\/comments&gt;<\/span>\r\n        <span class=\"nt\">&lt;concurrentlySchedulableTaskCount&gt;<\/span>1<span class=\"nt\">&lt;\/concurrentlySchedulableTaskCount&gt;<\/span>\r\n        <span class=\"nt\">&lt;descriptors&gt;<\/span>\r\n          <span class=\"nt\">&lt;entry&gt;<\/span>\r\n            <span class=\"nt\">&lt;key&gt;<\/span>Delete Attributes Expression<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n            <span class=\"nt\">&lt;value&gt;<\/span>\r\n              <span class=\"nt\">&lt;name&gt;<\/span>Delete Attributes Expression<span class=\"nt\">&lt;\/name&gt;<\/span>\r\n            <span class=\"nt\">&lt;\/value&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;entry&gt;<\/span>\r\n            <span class=\"nt\">&lt;key&gt;<\/span>Store State<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n            <span class=\"nt\">&lt;value&gt;<\/span>\r\n              <span class=\"nt\">&lt;name&gt;<\/span>Store State<span class=\"nt\">&lt;\/name&gt;<\/span>\r\n            <span class=\"nt\">&lt;\/value&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;entry&gt;<\/span>\r\n            <span class=\"nt\">&lt;key&gt;<\/span>Stateful Variables Initial Value<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n            <span class=\"nt\">&lt;value&gt;<\/span>\r\n              <span class=\"nt\">&lt;name&gt;<\/span>Stateful Variables Initial Value<span class=\"nt\">&lt;\/name&gt;<\/span>\r\n            <span class=\"nt\">&lt;\/value&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;entry&gt;<\/span>\r\n            <span class=\"nt\">&lt;key&gt;<\/span>schema.name<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n            <span class=\"nt\">&lt;value&gt;<\/span>\r\n              <span class=\"nt\">&lt;name&gt;<\/span>schema.name<span class=\"nt\">&lt;\/name&gt;<\/span>\r\n            <span class=\"nt\">&lt;\/value&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n        <span class=\"nt\">&lt;\/descriptors&gt;<\/span>\r\n        <span class=\"nt\">&lt;executionNode&gt;<\/span>ALL<span class=\"nt\">&lt;\/executionNode&gt;<\/span>\r\n        <span class=\"nt\">&lt;lossTolerant&gt;<\/span>false<span class=\"nt\">&lt;\/lossTolerant&gt;<\/span>\r\n        <span class=\"nt\">&lt;penaltyDuration&gt;<\/span>30 sec<span class=\"nt\">&lt;\/penaltyDuration&gt;<\/span>\r\n        <span class=\"nt\">&lt;properties&gt;<\/span>\r\n          <span class=\"nt\">&lt;entry&gt;<\/span>\r\n            <span class=\"nt\">&lt;key&gt;<\/span>Delete Attributes Expression<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;entry&gt;<\/span>\r\n            <span class=\"nt\">&lt;key&gt;<\/span>Store State<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n            <span class=\"nt\">&lt;value&gt;<\/span>Do not store state<span class=\"nt\">&lt;\/value&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;entry&gt;<\/span>\r\n            <span class=\"nt\">&lt;key&gt;<\/span>Stateful Variables Initial Value<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;entry&gt;<\/span>\r\n            <span class=\"nt\">&lt;key&gt;<\/span>schema.name<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n            <span class=\"nt\">&lt;value&gt;<\/span>movies<span class=\"nt\">&lt;\/value&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n        <span class=\"nt\">&lt;\/properties&gt;<\/span>\r\n        <span class=\"nt\">&lt;runDurationMillis&gt;<\/span>0<span class=\"nt\">&lt;\/runDurationMillis&gt;<\/span>\r\n        <span class=\"nt\">&lt;schedulingPeriod&gt;<\/span>0 sec<span class=\"nt\">&lt;\/schedulingPeriod&gt;<\/span>\r\n        <span class=\"nt\">&lt;schedulingStrategy&gt;<\/span>TIMER_DRIVEN<span class=\"nt\">&lt;\/schedulingStrategy&gt;<\/span>\r\n        <span class=\"nt\">&lt;yieldDuration&gt;<\/span>1 sec<span class=\"nt\">&lt;\/yieldDuration&gt;<\/span>\r\n      <span class=\"nt\">&lt;\/config&gt;<\/span>\r\n      <span class=\"nt\">&lt;name&gt;<\/span>Add Schema Name Attribute<span class=\"nt\">&lt;\/name&gt;<\/span>\r\n      <span class=\"nt\">&lt;relationships&gt;<\/span>\r\n        <span class=\"nt\">&lt;autoTerminate&gt;<\/span>false<span class=\"nt\">&lt;\/autoTerminate&gt;<\/span>\r\n        <span class=\"nt\">&lt;name&gt;<\/span>success<span class=\"nt\">&lt;\/name&gt;<\/span>\r\n      <span class=\"nt\">&lt;\/relationships&gt;<\/span>\r\n      <span class=\"nt\">&lt;style&gt;&lt;\/style&gt;<\/span>\r\n      <span class=\"nt\">&lt;type&gt;<\/span>org.apache.nifi.processors.attributes.UpdateAttribute<span class=\"nt\">&lt;\/type&gt;<\/span>\r\n    <span class=\"nt\">&lt;\/processors&gt;<\/span>\r\n    <span class=\"nt\">&lt;processors&gt;<\/span>\r\n      <span class=\"nt\">&lt;id&gt;<\/span>3f560dd9-2a0c-3090-0000-000000000000<span class=\"nt\">&lt;\/id&gt;<\/span>\r\n      <span class=\"nt\">&lt;parentGroupId&gt;<\/span>451a635e-0803-3845-0000-000000000000<span class=\"nt\">&lt;\/parentGroupId&gt;<\/span>\r\n      <span class=\"nt\">&lt;position&gt;<\/span>\r\n        <span class=\"nt\">&lt;x&gt;<\/span>588.3389261227253<span class=\"nt\">&lt;\/x&gt;<\/span>\r\n        <span class=\"nt\">&lt;y&gt;<\/span>645.9336127468443<span class=\"nt\">&lt;\/y&gt;<\/span>\r\n      <span class=\"nt\">&lt;\/position&gt;<\/span>\r\n      <span class=\"nt\">&lt;bundle&gt;<\/span>\r\n        <span class=\"nt\">&lt;artifact&gt;<\/span>nifi-kafka-0-10-nar<span class=\"nt\">&lt;\/artifact&gt;<\/span>\r\n        <span class=\"nt\">&lt;group&gt;<\/span>org.apache.nifi<span class=\"nt\">&lt;\/group&gt;<\/span>\r\n        <span class=\"nt\">&lt;version&gt;<\/span>1.3.0<span class=\"nt\">&lt;\/version&gt;<\/span>\r\n      <span class=\"nt\">&lt;\/bundle&gt;<\/span>\r\n      <span class=\"nt\">&lt;config&gt;<\/span>\r\n        <span class=\"nt\">&lt;bulletinLevel&gt;<\/span>WARN<span class=\"nt\">&lt;\/bulletinLevel&gt;<\/span>\r\n        <span class=\"nt\">&lt;comments&gt;&lt;\/comments&gt;<\/span>\r\n        <span class=\"nt\">&lt;concurrentlySchedulableTaskCount&gt;<\/span>1<span class=\"nt\">&lt;\/concurrentlySchedulableTaskCount&gt;<\/span>\r\n        <span class=\"nt\">&lt;descriptors&gt;<\/span>\r\n          <span class=\"nt\">&lt;entry&gt;<\/span>\r\n            <span class=\"nt\">&lt;key&gt;<\/span>bootstrap.servers<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n            <span class=\"nt\">&lt;value&gt;<\/span>\r\n              <span class=\"nt\">&lt;name&gt;<\/span>bootstrap.servers<span class=\"nt\">&lt;\/name&gt;<\/span>\r\n            <span class=\"nt\">&lt;\/value&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;entry&gt;<\/span>\r\n            <span class=\"nt\">&lt;key&gt;<\/span>topic<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n            <span class=\"nt\">&lt;value&gt;<\/span>\r\n              <span class=\"nt\">&lt;name&gt;<\/span>topic<span class=\"nt\">&lt;\/name&gt;<\/span>\r\n            <span class=\"nt\">&lt;\/value&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;entry&gt;<\/span>\r\n            <span class=\"nt\">&lt;key&gt;<\/span>record-reader<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n            <span class=\"nt\">&lt;value&gt;<\/span>\r\n              <span class=\"nt\">&lt;identifiesControllerService&gt;<\/span>org.apache.nifi.serialization.RecordReaderFactory<span class=\"nt\">&lt;\/identifiesControllerService&gt;<\/span>\r\n              <span class=\"nt\">&lt;name&gt;<\/span>record-reader<span class=\"nt\">&lt;\/name&gt;<\/span>\r\n            <span class=\"nt\">&lt;\/value&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;entry&gt;<\/span>\r\n            <span class=\"nt\">&lt;key&gt;<\/span>record-writer<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n            <span class=\"nt\">&lt;value&gt;<\/span>\r\n              <span class=\"nt\">&lt;identifiesControllerService&gt;<\/span>org.apache.nifi.serialization.RecordSetWriterFactory<span class=\"nt\">&lt;\/identifiesControllerService&gt;<\/span>\r\n              <span class=\"nt\">&lt;name&gt;<\/span>record-writer<span class=\"nt\">&lt;\/name&gt;<\/span>\r\n            <span class=\"nt\">&lt;\/value&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;entry&gt;<\/span>\r\n            <span class=\"nt\">&lt;key&gt;<\/span>security.protocol<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n            <span class=\"nt\">&lt;value&gt;<\/span>\r\n              <span class=\"nt\">&lt;name&gt;<\/span>security.protocol<span class=\"nt\">&lt;\/name&gt;<\/span>\r\n            <span class=\"nt\">&lt;\/value&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;entry&gt;<\/span>\r\n            <span class=\"nt\">&lt;key&gt;<\/span>sasl.kerberos.service.name<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n            <span class=\"nt\">&lt;value&gt;<\/span>\r\n              <span class=\"nt\">&lt;name&gt;<\/span>sasl.kerberos.service.name<span class=\"nt\">&lt;\/name&gt;<\/span>\r\n            <span class=\"nt\">&lt;\/value&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;entry&gt;<\/span>\r\n            <span class=\"nt\">&lt;key&gt;<\/span>sasl.kerberos.principal<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n            <span class=\"nt\">&lt;value&gt;<\/span>\r\n              <span class=\"nt\">&lt;name&gt;<\/span>sasl.kerberos.principal<span class=\"nt\">&lt;\/name&gt;<\/span>\r\n            <span class=\"nt\">&lt;\/value&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;entry&gt;<\/span>\r\n            <span class=\"nt\">&lt;key&gt;<\/span>sasl.kerberos.keytab<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n            <span class=\"nt\">&lt;value&gt;<\/span>\r\n              <span class=\"nt\">&lt;name&gt;<\/span>sasl.kerberos.keytab<span class=\"nt\">&lt;\/name&gt;<\/span>\r\n            <span class=\"nt\">&lt;\/value&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;entry&gt;<\/span>\r\n            <span class=\"nt\">&lt;key&gt;<\/span>ssl.context.service<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n            <span class=\"nt\">&lt;value&gt;<\/span>\r\n              <span class=\"nt\">&lt;identifiesControllerService&gt;<\/span>org.apache.nifi.ssl.SSLContextService<span class=\"nt\">&lt;\/identifiesControllerService&gt;<\/span>\r\n              <span class=\"nt\">&lt;name&gt;<\/span>ssl.context.service<span class=\"nt\">&lt;\/name&gt;<\/span>\r\n            <span class=\"nt\">&lt;\/value&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;entry&gt;<\/span>\r\n            <span class=\"nt\">&lt;key&gt;<\/span>acks<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n            <span class=\"nt\">&lt;value&gt;<\/span>\r\n              <span class=\"nt\">&lt;name&gt;<\/span>acks<span class=\"nt\">&lt;\/name&gt;<\/span>\r\n            <span class=\"nt\">&lt;\/value&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;entry&gt;<\/span>\r\n            <span class=\"nt\">&lt;key&gt;<\/span>message-key-field<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n            <span class=\"nt\">&lt;value&gt;<\/span>\r\n              <span class=\"nt\">&lt;name&gt;<\/span>message-key-field<span class=\"nt\">&lt;\/name&gt;<\/span>\r\n            <span class=\"nt\">&lt;\/value&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;entry&gt;<\/span>\r\n            <span class=\"nt\">&lt;key&gt;<\/span>max.request.size<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n            <span class=\"nt\">&lt;value&gt;<\/span>\r\n              <span class=\"nt\">&lt;name&gt;<\/span>max.request.size<span class=\"nt\">&lt;\/name&gt;<\/span>\r\n            <span class=\"nt\">&lt;\/value&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;entry&gt;<\/span>\r\n            <span class=\"nt\">&lt;key&gt;<\/span>ack.wait.time<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n            <span class=\"nt\">&lt;value&gt;<\/span>\r\n              <span class=\"nt\">&lt;name&gt;<\/span>ack.wait.time<span class=\"nt\">&lt;\/name&gt;<\/span>\r\n            <span class=\"nt\">&lt;\/value&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;entry&gt;<\/span>\r\n            <span class=\"nt\">&lt;key&gt;<\/span>max.block.ms<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n            <span class=\"nt\">&lt;value&gt;<\/span>\r\n              <span class=\"nt\">&lt;name&gt;<\/span>max.block.ms<span class=\"nt\">&lt;\/name&gt;<\/span>\r\n            <span class=\"nt\">&lt;\/value&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;entry&gt;<\/span>\r\n            <span class=\"nt\">&lt;key&gt;<\/span>partitioner.class<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n            <span class=\"nt\">&lt;value&gt;<\/span>\r\n              <span class=\"nt\">&lt;name&gt;<\/span>partitioner.class<span class=\"nt\">&lt;\/name&gt;<\/span>\r\n            <span class=\"nt\">&lt;\/value&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;entry&gt;<\/span>\r\n            <span class=\"nt\">&lt;key&gt;<\/span>compression.type<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n            <span class=\"nt\">&lt;value&gt;<\/span>\r\n              <span class=\"nt\">&lt;name&gt;<\/span>compression.type<span class=\"nt\">&lt;\/name&gt;<\/span>\r\n            <span class=\"nt\">&lt;\/value&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n        <span class=\"nt\">&lt;\/descriptors&gt;<\/span>\r\n        <span class=\"nt\">&lt;executionNode&gt;<\/span>ALL<span class=\"nt\">&lt;\/executionNode&gt;<\/span>\r\n        <span class=\"nt\">&lt;lossTolerant&gt;<\/span>false<span class=\"nt\">&lt;\/lossTolerant&gt;<\/span>\r\n        <span class=\"nt\">&lt;penaltyDuration&gt;<\/span>30 sec<span class=\"nt\">&lt;\/penaltyDuration&gt;<\/span>\r\n        <span class=\"nt\">&lt;properties&gt;<\/span>\r\n          <span class=\"nt\">&lt;entry&gt;<\/span>\r\n            <span class=\"nt\">&lt;key&gt;<\/span>bootstrap.servers<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n            <span class=\"nt\">&lt;value&gt;<\/span>localhost:9092<span class=\"nt\">&lt;\/value&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;entry&gt;<\/span>\r\n            <span class=\"nt\">&lt;key&gt;<\/span>topic<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n            <span class=\"nt\">&lt;value&gt;<\/span>Movies<span class=\"nt\">&lt;\/value&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;entry&gt;<\/span>\r\n            <span class=\"nt\">&lt;key&gt;<\/span>record-reader<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n            <span class=\"nt\">&lt;value&gt;<\/span>b8531252-2a7c-3648-0000-000000000000<span class=\"nt\">&lt;\/value&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;entry&gt;<\/span>\r\n            <span class=\"nt\">&lt;key&gt;<\/span>record-writer<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n            <span class=\"nt\">&lt;value&gt;<\/span>290d56c9-1e35-3dba-0000-000000000000<span class=\"nt\">&lt;\/value&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;entry&gt;<\/span>\r\n            <span class=\"nt\">&lt;key&gt;<\/span>security.protocol<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n            <span class=\"nt\">&lt;value&gt;<\/span>PLAINTEXT<span class=\"nt\">&lt;\/value&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;entry&gt;<\/span>\r\n            <span class=\"nt\">&lt;key&gt;<\/span>sasl.kerberos.service.name<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;entry&gt;<\/span>\r\n            <span class=\"nt\">&lt;key&gt;<\/span>sasl.kerberos.principal<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;entry&gt;<\/span>\r\n            <span class=\"nt\">&lt;key&gt;<\/span>sasl.kerberos.keytab<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;entry&gt;<\/span>\r\n            <span class=\"nt\">&lt;key&gt;<\/span>ssl.context.service<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;entry&gt;<\/span>\r\n            <span class=\"nt\">&lt;key&gt;<\/span>acks<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n            <span class=\"nt\">&lt;value&gt;<\/span>0<span class=\"nt\">&lt;\/value&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;entry&gt;<\/span>\r\n            <span class=\"nt\">&lt;key&gt;<\/span>message-key-field<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;entry&gt;<\/span>\r\n            <span class=\"nt\">&lt;key&gt;<\/span>max.request.size<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n            <span class=\"nt\">&lt;value&gt;<\/span>1 MB<span class=\"nt\">&lt;\/value&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;entry&gt;<\/span>\r\n            <span class=\"nt\">&lt;key&gt;<\/span>ack.wait.time<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n            <span class=\"nt\">&lt;value&gt;<\/span>5 secs<span class=\"nt\">&lt;\/value&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;entry&gt;<\/span>\r\n            <span class=\"nt\">&lt;key&gt;<\/span>max.block.ms<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n            <span class=\"nt\">&lt;value&gt;<\/span>5 sec<span class=\"nt\">&lt;\/value&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;entry&gt;<\/span>\r\n            <span class=\"nt\">&lt;key&gt;<\/span>partitioner.class<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n            <span class=\"nt\">&lt;value&gt;<\/span>org.apache.kafka.clients.producer.internals.DefaultPartitioner<span class=\"nt\">&lt;\/value&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;entry&gt;<\/span>\r\n            <span class=\"nt\">&lt;key&gt;<\/span>compression.type<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n            <span class=\"nt\">&lt;value&gt;<\/span>none<span class=\"nt\">&lt;\/value&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n        <span class=\"nt\">&lt;\/properties&gt;<\/span>\r\n        <span class=\"nt\">&lt;runDurationMillis&gt;<\/span>0<span class=\"nt\">&lt;\/runDurationMillis&gt;<\/span>\r\n        <span class=\"nt\">&lt;schedulingPeriod&gt;<\/span>0 sec<span class=\"nt\">&lt;\/schedulingPeriod&gt;<\/span>\r\n        <span class=\"nt\">&lt;schedulingStrategy&gt;<\/span>TIMER_DRIVEN<span class=\"nt\">&lt;\/schedulingStrategy&gt;<\/span>\r\n        <span class=\"nt\">&lt;yieldDuration&gt;<\/span>1 sec<span class=\"nt\">&lt;\/yieldDuration&gt;<\/span>\r\n      <span class=\"nt\">&lt;\/config&gt;<\/span>\r\n      <span class=\"nt\">&lt;name&gt;<\/span>Publish to \"Movies\" Topic<span class=\"nt\">&lt;\/name&gt;<\/span>\r\n      <span class=\"nt\">&lt;relationships&gt;<\/span>\r\n        <span class=\"nt\">&lt;autoTerminate&gt;<\/span>false<span class=\"nt\">&lt;\/autoTerminate&gt;<\/span>\r\n        <span class=\"nt\">&lt;name&gt;<\/span>failure<span class=\"nt\">&lt;\/name&gt;<\/span>\r\n      <span class=\"nt\">&lt;\/relationships&gt;<\/span>\r\n      <span class=\"nt\">&lt;relationships&gt;<\/span>\r\n        <span class=\"nt\">&lt;autoTerminate&gt;<\/span>true<span class=\"nt\">&lt;\/autoTerminate&gt;<\/span>\r\n        <span class=\"nt\">&lt;name&gt;<\/span>success<span class=\"nt\">&lt;\/name&gt;<\/span>\r\n      <span class=\"nt\">&lt;\/relationships&gt;<\/span>\r\n      <span class=\"nt\">&lt;style&gt;&lt;\/style&gt;<\/span>\r\n      <span class=\"nt\">&lt;type&gt;<\/span>org.apache.nifi.processors.kafka.pubsub.PublishKafkaRecord_0_10<span class=\"nt\">&lt;\/type&gt;<\/span>\r\n    <span class=\"nt\">&lt;\/processors&gt;<\/span>\r\n    <span class=\"nt\">&lt;processors&gt;<\/span>\r\n      <span class=\"nt\">&lt;id&gt;<\/span>4004c547-2a1a-321b-0000-000000000000<span class=\"nt\">&lt;\/id&gt;<\/span>\r\n      <span class=\"nt\">&lt;parentGroupId&gt;<\/span>451a635e-0803-3845-0000-000000000000<span class=\"nt\">&lt;\/parentGroupId&gt;<\/span>\r\n      <span class=\"nt\">&lt;position&gt;<\/span>\r\n        <span class=\"nt\">&lt;x&gt;<\/span>0.0<span class=\"nt\">&lt;\/x&gt;<\/span>\r\n        <span class=\"nt\">&lt;y&gt;<\/span>0.0<span class=\"nt\">&lt;\/y&gt;<\/span>\r\n      <span class=\"nt\">&lt;\/position&gt;<\/span>\r\n      <span class=\"nt\">&lt;bundle&gt;<\/span>\r\n        <span class=\"nt\">&lt;artifact&gt;<\/span>nifi-standard-nar<span class=\"nt\">&lt;\/artifact&gt;<\/span>\r\n        <span class=\"nt\">&lt;group&gt;<\/span>org.apache.nifi<span class=\"nt\">&lt;\/group&gt;<\/span>\r\n        <span class=\"nt\">&lt;version&gt;<\/span>1.3.0<span class=\"nt\">&lt;\/version&gt;<\/span>\r\n      <span class=\"nt\">&lt;\/bundle&gt;<\/span>\r\n      <span class=\"nt\">&lt;config&gt;<\/span>\r\n        <span class=\"nt\">&lt;bulletinLevel&gt;<\/span>WARN<span class=\"nt\">&lt;\/bulletinLevel&gt;<\/span>\r\n        <span class=\"nt\">&lt;comments&gt;&lt;\/comments&gt;<\/span>\r\n        <span class=\"nt\">&lt;concurrentlySchedulableTaskCount&gt;<\/span>1<span class=\"nt\">&lt;\/concurrentlySchedulableTaskCount&gt;<\/span>\r\n        <span class=\"nt\">&lt;descriptors&gt;<\/span>\r\n          <span class=\"nt\">&lt;entry&gt;<\/span>\r\n            <span class=\"nt\">&lt;key&gt;<\/span>URL<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n            <span class=\"nt\">&lt;value&gt;<\/span>\r\n              <span class=\"nt\">&lt;name&gt;<\/span>URL<span class=\"nt\">&lt;\/name&gt;<\/span>\r\n            <span class=\"nt\">&lt;\/value&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;entry&gt;<\/span>\r\n            <span class=\"nt\">&lt;key&gt;<\/span>Filename<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n            <span class=\"nt\">&lt;value&gt;<\/span>\r\n              <span class=\"nt\">&lt;name&gt;<\/span>Filename<span class=\"nt\">&lt;\/name&gt;<\/span>\r\n            <span class=\"nt\">&lt;\/value&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;entry&gt;<\/span>\r\n            <span class=\"nt\">&lt;key&gt;<\/span>SSL Context Service<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n            <span class=\"nt\">&lt;value&gt;<\/span>\r\n              <span class=\"nt\">&lt;identifiesControllerService&gt;<\/span>org.apache.nifi.ssl.SSLContextService<span class=\"nt\">&lt;\/identifiesControllerService&gt;<\/span>\r\n              <span class=\"nt\">&lt;name&gt;<\/span>SSL Context Service<span class=\"nt\">&lt;\/name&gt;<\/span>\r\n            <span class=\"nt\">&lt;\/value&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;entry&gt;<\/span>\r\n            <span class=\"nt\">&lt;key&gt;<\/span>Username<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n            <span class=\"nt\">&lt;value&gt;<\/span>\r\n              <span class=\"nt\">&lt;name&gt;<\/span>Username<span class=\"nt\">&lt;\/name&gt;<\/span>\r\n            <span class=\"nt\">&lt;\/value&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;entry&gt;<\/span>\r\n            <span class=\"nt\">&lt;key&gt;<\/span>Password<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n            <span class=\"nt\">&lt;value&gt;<\/span>\r\n              <span class=\"nt\">&lt;name&gt;<\/span>Password<span class=\"nt\">&lt;\/name&gt;<\/span>\r\n            <span class=\"nt\">&lt;\/value&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;entry&gt;<\/span>\r\n            <span class=\"nt\">&lt;key&gt;<\/span>Connection Timeout<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n            <span class=\"nt\">&lt;value&gt;<\/span>\r\n              <span class=\"nt\">&lt;name&gt;<\/span>Connection Timeout<span class=\"nt\">&lt;\/name&gt;<\/span>\r\n            <span class=\"nt\">&lt;\/value&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;entry&gt;<\/span>\r\n            <span class=\"nt\">&lt;key&gt;<\/span>Data Timeout<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n            <span class=\"nt\">&lt;value&gt;<\/span>\r\n              <span class=\"nt\">&lt;name&gt;<\/span>Data Timeout<span class=\"nt\">&lt;\/name&gt;<\/span>\r\n            <span class=\"nt\">&lt;\/value&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;entry&gt;<\/span>\r\n            <span class=\"nt\">&lt;key&gt;<\/span>User Agent<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n            <span class=\"nt\">&lt;value&gt;<\/span>\r\n              <span class=\"nt\">&lt;name&gt;<\/span>User Agent<span class=\"nt\">&lt;\/name&gt;<\/span>\r\n            <span class=\"nt\">&lt;\/value&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;entry&gt;<\/span>\r\n            <span class=\"nt\">&lt;key&gt;<\/span>Accept Content-Type<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n            <span class=\"nt\">&lt;value&gt;<\/span>\r\n              <span class=\"nt\">&lt;name&gt;<\/span>Accept Content-Type<span class=\"nt\">&lt;\/name&gt;<\/span>\r\n            <span class=\"nt\">&lt;\/value&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;entry&gt;<\/span>\r\n            <span class=\"nt\">&lt;key&gt;<\/span>Follow Redirects<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n            <span class=\"nt\">&lt;value&gt;<\/span>\r\n              <span class=\"nt\">&lt;name&gt;<\/span>Follow Redirects<span class=\"nt\">&lt;\/name&gt;<\/span>\r\n            <span class=\"nt\">&lt;\/value&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;entry&gt;<\/span>\r\n            <span class=\"nt\">&lt;key&gt;<\/span>redirect-cookie-policy<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n            <span class=\"nt\">&lt;value&gt;<\/span>\r\n              <span class=\"nt\">&lt;name&gt;<\/span>redirect-cookie-policy<span class=\"nt\">&lt;\/name&gt;<\/span>\r\n            <span class=\"nt\">&lt;\/value&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;entry&gt;<\/span>\r\n            <span class=\"nt\">&lt;key&gt;<\/span>Proxy Host<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n            <span class=\"nt\">&lt;value&gt;<\/span>\r\n              <span class=\"nt\">&lt;name&gt;<\/span>Proxy Host<span class=\"nt\">&lt;\/name&gt;<\/span>\r\n            <span class=\"nt\">&lt;\/value&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;entry&gt;<\/span>\r\n            <span class=\"nt\">&lt;key&gt;<\/span>Proxy Port<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n            <span class=\"nt\">&lt;value&gt;<\/span>\r\n              <span class=\"nt\">&lt;name&gt;<\/span>Proxy Port<span class=\"nt\">&lt;\/name&gt;<\/span>\r\n            <span class=\"nt\">&lt;\/value&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n        <span class=\"nt\">&lt;\/descriptors&gt;<\/span>\r\n        <span class=\"nt\">&lt;executionNode&gt;<\/span>ALL<span class=\"nt\">&lt;\/executionNode&gt;<\/span>\r\n        <span class=\"nt\">&lt;lossTolerant&gt;<\/span>false<span class=\"nt\">&lt;\/lossTolerant&gt;<\/span>\r\n        <span class=\"nt\">&lt;penaltyDuration&gt;<\/span>30 sec<span class=\"nt\">&lt;\/penaltyDuration&gt;<\/span>\r\n        <span class=\"nt\">&lt;properties&gt;<\/span>\r\n          <span class=\"nt\">&lt;entry&gt;<\/span>\r\n            <span class=\"nt\">&lt;key&gt;<\/span>URL<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n            <span class=\"nt\">&lt;value&gt;<\/span>http:\/\/files.grouplens.org\/datasets\/movielens\/ml-20m.zip<span class=\"nt\">&lt;\/value&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;entry&gt;<\/span>\r\n            <span class=\"nt\">&lt;key&gt;<\/span>Filename<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n            <span class=\"nt\">&lt;value&gt;<\/span>ml-20m.zip<span class=\"nt\">&lt;\/value&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;entry&gt;<\/span>\r\n            <span class=\"nt\">&lt;key&gt;<\/span>SSL Context Service<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;entry&gt;<\/span>\r\n            <span class=\"nt\">&lt;key&gt;<\/span>Username<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;entry&gt;<\/span>\r\n            <span class=\"nt\">&lt;key&gt;<\/span>Password<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;entry&gt;<\/span>\r\n            <span class=\"nt\">&lt;key&gt;<\/span>Connection Timeout<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n            <span class=\"nt\">&lt;value&gt;<\/span>30 sec<span class=\"nt\">&lt;\/value&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;entry&gt;<\/span>\r\n            <span class=\"nt\">&lt;key&gt;<\/span>Data Timeout<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n            <span class=\"nt\">&lt;value&gt;<\/span>30 sec<span class=\"nt\">&lt;\/value&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;entry&gt;<\/span>\r\n            <span class=\"nt\">&lt;key&gt;<\/span>User Agent<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;entry&gt;<\/span>\r\n            <span class=\"nt\">&lt;key&gt;<\/span>Accept Content-Type<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;entry&gt;<\/span>\r\n            <span class=\"nt\">&lt;key&gt;<\/span>Follow Redirects<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n            <span class=\"nt\">&lt;value&gt;<\/span>false<span class=\"nt\">&lt;\/value&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;entry&gt;<\/span>\r\n            <span class=\"nt\">&lt;key&gt;<\/span>redirect-cookie-policy<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n            <span class=\"nt\">&lt;value&gt;<\/span>default<span class=\"nt\">&lt;\/value&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;entry&gt;<\/span>\r\n            <span class=\"nt\">&lt;key&gt;<\/span>Proxy Host<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n          <span class=\"nt\">&lt;entry&gt;<\/span>\r\n            <span class=\"nt\">&lt;key&gt;<\/span>Proxy Port<span class=\"nt\">&lt;\/key&gt;<\/span>\r\n          <span class=\"nt\">&lt;\/entry&gt;<\/span>\r\n        <span class=\"nt\">&lt;\/properties&gt;<\/span>\r\n        <span class=\"nt\">&lt;runDurationMillis&gt;<\/span>0<span class=\"nt\">&lt;\/runDurationMillis&gt;<\/span>\r\n        <span class=\"nt\">&lt;schedulingPeriod&gt;<\/span>10 mins<span class=\"nt\">&lt;\/schedulingPeriod&gt;<\/span>\r\n        <span class=\"nt\">&lt;schedulingStrategy&gt;<\/span>TIMER_DRIVEN<span class=\"nt\">&lt;\/schedulingStrategy&gt;<\/span>\r\n        <span class=\"nt\">&lt;yieldDuration&gt;<\/span>1 sec<span class=\"nt\">&lt;\/yieldDuration&gt;<\/span>\r\n      <span class=\"nt\">&lt;\/config&gt;<\/span>\r\n      <span class=\"nt\">&lt;name&gt;<\/span>Get Movie Data<span class=\"nt\">&lt;\/name&gt;<\/span>\r\n      <span class=\"nt\">&lt;relationships&gt;<\/span>\r\n        <span class=\"nt\">&lt;autoTerminate&gt;<\/span>false<span class=\"nt\">&lt;\/autoTerminate&gt;<\/span>\r\n        <span class=\"nt\">&lt;name&gt;<\/span>success<span class=\"nt\">&lt;\/name&gt;<\/span>\r\n      <span class=\"nt\">&lt;\/relationships&gt;<\/span>\r\n      <span class=\"nt\">&lt;style&gt;&lt;\/style&gt;<\/span>\r\n      <span class=\"nt\">&lt;type&gt;<\/span>org.apache.nifi.processors.standard.GetHTTP<span class=\"nt\">&lt;\/type&gt;<\/span>\r\n    <span class=\"nt\">&lt;\/processors&gt;<\/span>\r\n  <span class=\"nt\">&lt;\/snippet&gt;<\/span>\r\n  <span class=\"nt\">&lt;timestamp&gt;<\/span>09\/11\/2017 11:33:49 EDT<span class=\"nt\">&lt;\/timestamp&gt;<\/span>\r\n<span class=\"nt\">&lt;\/template&gt;<\/span>\r\n<\/code><\/pre>\n<h1>\u8bf7\u53c2\u8003\u4ee5\u4e0b\u8d44\u6599<\/h1>\n<p>\u8bf7\u67e5\u770b\u4e0b\u5217\u53c2\u8003\u8d44\u6599<\/p>\n<p>\u60a8\u53ef\u4ee5\u53c2\u8003\u4ee5\u4e0b\u8d44\u6599<\/p>\n<ul class=\"post-ul\">Using PublishKafkaRecord_0_10 (CSVReader\/JSONWriter) in Apache NiFi 1.2+<\/ul>\n","protected":false},"excerpt":{"rendered":"<p>\u4e3a\u4e86\u8fbe\u5230\u7279\u5b9a\u7684\u76ee\u6807\u6216\u7ed3\u679c \u4f7f\u7528NiFi HTTP\u5904\u7406\u5668\u83b7\u53d6\u548c\u89e3\u538b\u6587\u4ef6\uff0c\u7136\u540e\u5c06\u7279\u5b9a\u6a21\u5f0f\u7684\u6587\u4ef6\u8fdb\u884c\u6574\u7406\uff0c\u5e76\u5c06\u5176\u53d1\u9001 [&hellip;]<\/p>\n","protected":false},"author":3,"featured_media":0,"comment_status":"closed","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[1],"tags":[],"class_list":["post-47119","post","type-post","status-publish","format-standard","hentry","category-uncategorized"],"yoast_head":"<!-- This site is optimized with the Yoast SEO Premium plugin v21.5 (Yoast SEO v21.5) - https:\/\/yoast.com\/wordpress\/plugins\/seo\/ -->\n<title>\u4f7f\u7528NiFi HTTP\u5904\u7406\u5668\u6765\u83b7\u53d6\u5e76\u89e3\u538b\u6587\u4ef6\uff0c\u7136\u540e\u5c06\u6307\u5b9a\u6a21\u5f0f\u7684\u6587\u4ef6\u6574\u7406\u540e\u53d1\u9001\u5230Kafka - Blog - Silicon Cloud<\/title>\n<meta name=\"robots\" content=\"index, follow, max-snippet:-1, max-image-preview:large, max-video-preview:-1\" \/>\n<link rel=\"canonical\" href=\"https:\/\/www.silicloud.com\/zh\/blog\/\u4f7f\u7528nifi-http\u5904\u7406\u5668\u6765\u83b7\u53d6\u5e76\u89e3\u538b\u6587\u4ef6\uff0c\u7136\u540e\u5c06\u6307\u5b9a\u6a21\u5f0f\/\" \/>\n<meta property=\"og:locale\" content=\"zh_CN\" \/>\n<meta property=\"og:type\" content=\"article\" \/>\n<meta property=\"og:title\" content=\"\u4f7f\u7528NiFi HTTP\u5904\u7406\u5668\u6765\u83b7\u53d6\u5e76\u89e3\u538b\u6587\u4ef6\uff0c\u7136\u540e\u5c06\u6307\u5b9a\u6a21\u5f0f\u7684\u6587\u4ef6\u6574\u7406\u540e\u53d1\u9001\u5230Kafka\" \/>\n<meta property=\"og:description\" content=\"\u4e3a\u4e86\u8fbe\u5230\u7279\u5b9a\u7684\u76ee\u6807\u6216\u7ed3\u679c \u4f7f\u7528NiFi HTTP\u5904\u7406\u5668\u83b7\u53d6\u548c\u89e3\u538b\u6587\u4ef6\uff0c\u7136\u540e\u5c06\u7279\u5b9a\u6a21\u5f0f\u7684\u6587\u4ef6\u8fdb\u884c\u6574\u7406\uff0c\u5e76\u5c06\u5176\u53d1\u9001 [&hellip;]\" \/>\n<meta property=\"og:url\" content=\"https:\/\/www.silicloud.com\/zh\/blog\/\u4f7f\u7528nifi-http\u5904\u7406\u5668\u6765\u83b7\u53d6\u5e76\u89e3\u538b\u6587\u4ef6\uff0c\u7136\u540e\u5c06\u6307\u5b9a\u6a21\u5f0f\/\" \/>\n<meta property=\"og:site_name\" content=\"Blog - Silicon Cloud\" \/>\n<meta property=\"article:published_time\" content=\"2023-03-28T15:55:27+00:00\" \/>\n<meta property=\"article:modified_time\" content=\"2024-04-30T02:05:09+00:00\" \/>\n<meta property=\"og:image\" content=\"https:\/\/cdn.silicloud.com\/blog-img\/blog\/img\/657d7c76913a08637a69c752\/10-0.png\" \/>\n<meta name=\"author\" content=\"\u97f5, \u79d1\" \/>\n<meta name=\"twitter:card\" content=\"summary_large_image\" \/>\n<meta name=\"twitter:label1\" content=\"\u4f5c\u8005\" \/>\n\t<meta name=\"twitter:data1\" content=\"\u97f5, \u79d1\" \/>\n\t<meta name=\"twitter:label2\" content=\"\u9884\u8ba1\u9605\u8bfb\u65f6\u95f4\" \/>\n\t<meta name=\"twitter:data2\" content=\"27 \u5206\" \/>\n<script type=\"application\/ld+json\" class=\"yoast-schema-graph\">{\"@context\":\"https:\/\/schema.org\",\"@graph\":[{\"@type\":\"WebPage\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/%e4%bd%bf%e7%94%a8nifi-http%e5%a4%84%e7%90%86%e5%99%a8%e6%9d%a5%e8%8e%b7%e5%8f%96%e5%b9%b6%e8%a7%a3%e5%8e%8b%e6%96%87%e4%bb%b6%ef%bc%8c%e7%84%b6%e5%90%8e%e5%b0%86%e6%8c%87%e5%ae%9a%e6%a8%a1%e5%bc%8f\/\",\"url\":\"https:\/\/www.silicloud.com\/zh\/blog\/%e4%bd%bf%e7%94%a8nifi-http%e5%a4%84%e7%90%86%e5%99%a8%e6%9d%a5%e8%8e%b7%e5%8f%96%e5%b9%b6%e8%a7%a3%e5%8e%8b%e6%96%87%e4%bb%b6%ef%bc%8c%e7%84%b6%e5%90%8e%e5%b0%86%e6%8c%87%e5%ae%9a%e6%a8%a1%e5%bc%8f\/\",\"name\":\"\u4f7f\u7528NiFi HTTP\u5904\u7406\u5668\u6765\u83b7\u53d6\u5e76\u89e3\u538b\u6587\u4ef6\uff0c\u7136\u540e\u5c06\u6307\u5b9a\u6a21\u5f0f\u7684\u6587\u4ef6\u6574\u7406\u540e\u53d1\u9001\u5230Kafka - Blog - Silicon Cloud\",\"isPartOf\":{\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#website\"},\"datePublished\":\"2023-03-28T15:55:27+00:00\",\"dateModified\":\"2024-04-30T02:05:09+00:00\",\"author\":{\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/6530331a63adef3b3443a1fab53a0e6e\"},\"breadcrumb\":{\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/%e4%bd%bf%e7%94%a8nifi-http%e5%a4%84%e7%90%86%e5%99%a8%e6%9d%a5%e8%8e%b7%e5%8f%96%e5%b9%b6%e8%a7%a3%e5%8e%8b%e6%96%87%e4%bb%b6%ef%bc%8c%e7%84%b6%e5%90%8e%e5%b0%86%e6%8c%87%e5%ae%9a%e6%a8%a1%e5%bc%8f\/#breadcrumb\"},\"inLanguage\":\"zh-Hans\",\"potentialAction\":[{\"@type\":\"ReadAction\",\"target\":[\"https:\/\/www.silicloud.com\/zh\/blog\/%e4%bd%bf%e7%94%a8nifi-http%e5%a4%84%e7%90%86%e5%99%a8%e6%9d%a5%e8%8e%b7%e5%8f%96%e5%b9%b6%e8%a7%a3%e5%8e%8b%e6%96%87%e4%bb%b6%ef%bc%8c%e7%84%b6%e5%90%8e%e5%b0%86%e6%8c%87%e5%ae%9a%e6%a8%a1%e5%bc%8f\/\"]}]},{\"@type\":\"BreadcrumbList\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/%e4%bd%bf%e7%94%a8nifi-http%e5%a4%84%e7%90%86%e5%99%a8%e6%9d%a5%e8%8e%b7%e5%8f%96%e5%b9%b6%e8%a7%a3%e5%8e%8b%e6%96%87%e4%bb%b6%ef%bc%8c%e7%84%b6%e5%90%8e%e5%b0%86%e6%8c%87%e5%ae%9a%e6%a8%a1%e5%bc%8f\/#breadcrumb\",\"itemListElement\":[{\"@type\":\"ListItem\",\"position\":1,\"name\":\"\u9996\u9875\",\"item\":\"https:\/\/www.silicloud.com\/zh\/blog\/\"},{\"@type\":\"ListItem\",\"position\":2,\"name\":\"\u4f7f\u7528NiFi HTTP\u5904\u7406\u5668\u6765\u83b7\u53d6\u5e76\u89e3\u538b\u6587\u4ef6\uff0c\u7136\u540e\u5c06\u6307\u5b9a\u6a21\u5f0f\u7684\u6587\u4ef6\u6574\u7406\u540e\u53d1\u9001\u5230Kafka\"}]},{\"@type\":\"WebSite\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#website\",\"url\":\"https:\/\/www.silicloud.com\/zh\/blog\/\",\"name\":\"Blog - Silicon Cloud\",\"description\":\"\",\"inLanguage\":\"zh-Hans\"},{\"@type\":\"Person\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/6530331a63adef3b3443a1fab53a0e6e\",\"name\":\"\u97f5, \u79d1\",\"image\":{\"@type\":\"ImageObject\",\"inLanguage\":\"zh-Hans\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/image\/\",\"url\":\"https:\/\/secure.gravatar.com\/avatar\/429ccb39b3fff5188bc17986222cfb0936cbadb8cc933cff04ab5ca01bd30a08?s=96&d=mm&r=g\",\"contentUrl\":\"https:\/\/secure.gravatar.com\/avatar\/429ccb39b3fff5188bc17986222cfb0936cbadb8cc933cff04ab5ca01bd30a08?s=96&d=mm&r=g\",\"caption\":\"\u97f5, \u79d1\"},\"url\":\"https:\/\/www.silicloud.com\/zh\/blog\/author\/yunke\/\"},{\"@type\":\"ImageObject\",\"inLanguage\":\"zh-Hans\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/%e4%bd%bf%e7%94%a8nifi-http%e5%a4%84%e7%90%86%e5%99%a8%e6%9d%a5%e8%8e%b7%e5%8f%96%e5%b9%b6%e8%a7%a3%e5%8e%8b%e6%96%87%e4%bb%b6%ef%bc%8c%e7%84%b6%e5%90%8e%e5%b0%86%e6%8c%87%e5%ae%9a%e6%a8%a1%e5%bc%8f\/#local-main-organization-logo\",\"url\":\"\",\"contentUrl\":\"\",\"caption\":\"Blog - Silicon Cloud\"}]}<\/script>\n<!-- \/ Yoast SEO Premium plugin. -->","yoast_head_json":{"title":"\u4f7f\u7528NiFi HTTP\u5904\u7406\u5668\u6765\u83b7\u53d6\u5e76\u89e3\u538b\u6587\u4ef6\uff0c\u7136\u540e\u5c06\u6307\u5b9a\u6a21\u5f0f\u7684\u6587\u4ef6\u6574\u7406\u540e\u53d1\u9001\u5230Kafka - Blog - Silicon Cloud","robots":{"index":"index","follow":"follow","max-snippet":"max-snippet:-1","max-image-preview":"max-image-preview:large","max-video-preview":"max-video-preview:-1"},"canonical":"https:\/\/www.silicloud.com\/zh\/blog\/\u4f7f\u7528nifi-http\u5904\u7406\u5668\u6765\u83b7\u53d6\u5e76\u89e3\u538b\u6587\u4ef6\uff0c\u7136\u540e\u5c06\u6307\u5b9a\u6a21\u5f0f\/","og_locale":"zh_CN","og_type":"article","og_title":"\u4f7f\u7528NiFi HTTP\u5904\u7406\u5668\u6765\u83b7\u53d6\u5e76\u89e3\u538b\u6587\u4ef6\uff0c\u7136\u540e\u5c06\u6307\u5b9a\u6a21\u5f0f\u7684\u6587\u4ef6\u6574\u7406\u540e\u53d1\u9001\u5230Kafka","og_description":"\u4e3a\u4e86\u8fbe\u5230\u7279\u5b9a\u7684\u76ee\u6807\u6216\u7ed3\u679c \u4f7f\u7528NiFi HTTP\u5904\u7406\u5668\u83b7\u53d6\u548c\u89e3\u538b\u6587\u4ef6\uff0c\u7136\u540e\u5c06\u7279\u5b9a\u6a21\u5f0f\u7684\u6587\u4ef6\u8fdb\u884c\u6574\u7406\uff0c\u5e76\u5c06\u5176\u53d1\u9001 [&hellip;]","og_url":"https:\/\/www.silicloud.com\/zh\/blog\/\u4f7f\u7528nifi-http\u5904\u7406\u5668\u6765\u83b7\u53d6\u5e76\u89e3\u538b\u6587\u4ef6\uff0c\u7136\u540e\u5c06\u6307\u5b9a\u6a21\u5f0f\/","og_site_name":"Blog - Silicon Cloud","article_published_time":"2023-03-28T15:55:27+00:00","article_modified_time":"2024-04-30T02:05:09+00:00","og_image":[{"url":"https:\/\/cdn.silicloud.com\/blog-img\/blog\/img\/657d7c76913a08637a69c752\/10-0.png"}],"author":"\u97f5, \u79d1","twitter_card":"summary_large_image","twitter_misc":{"\u4f5c\u8005":"\u97f5, \u79d1","\u9884\u8ba1\u9605\u8bfb\u65f6\u95f4":"27 \u5206"},"schema":{"@context":"https:\/\/schema.org","@graph":[{"@type":"WebPage","@id":"https:\/\/www.silicloud.com\/zh\/blog\/%e4%bd%bf%e7%94%a8nifi-http%e5%a4%84%e7%90%86%e5%99%a8%e6%9d%a5%e8%8e%b7%e5%8f%96%e5%b9%b6%e8%a7%a3%e5%8e%8b%e6%96%87%e4%bb%b6%ef%bc%8c%e7%84%b6%e5%90%8e%e5%b0%86%e6%8c%87%e5%ae%9a%e6%a8%a1%e5%bc%8f\/","url":"https:\/\/www.silicloud.com\/zh\/blog\/%e4%bd%bf%e7%94%a8nifi-http%e5%a4%84%e7%90%86%e5%99%a8%e6%9d%a5%e8%8e%b7%e5%8f%96%e5%b9%b6%e8%a7%a3%e5%8e%8b%e6%96%87%e4%bb%b6%ef%bc%8c%e7%84%b6%e5%90%8e%e5%b0%86%e6%8c%87%e5%ae%9a%e6%a8%a1%e5%bc%8f\/","name":"\u4f7f\u7528NiFi HTTP\u5904\u7406\u5668\u6765\u83b7\u53d6\u5e76\u89e3\u538b\u6587\u4ef6\uff0c\u7136\u540e\u5c06\u6307\u5b9a\u6a21\u5f0f\u7684\u6587\u4ef6\u6574\u7406\u540e\u53d1\u9001\u5230Kafka - Blog - Silicon Cloud","isPartOf":{"@id":"https:\/\/www.silicloud.com\/zh\/blog\/#website"},"datePublished":"2023-03-28T15:55:27+00:00","dateModified":"2024-04-30T02:05:09+00:00","author":{"@id":"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/6530331a63adef3b3443a1fab53a0e6e"},"breadcrumb":{"@id":"https:\/\/www.silicloud.com\/zh\/blog\/%e4%bd%bf%e7%94%a8nifi-http%e5%a4%84%e7%90%86%e5%99%a8%e6%9d%a5%e8%8e%b7%e5%8f%96%e5%b9%b6%e8%a7%a3%e5%8e%8b%e6%96%87%e4%bb%b6%ef%bc%8c%e7%84%b6%e5%90%8e%e5%b0%86%e6%8c%87%e5%ae%9a%e6%a8%a1%e5%bc%8f\/#breadcrumb"},"inLanguage":"zh-Hans","potentialAction":[{"@type":"ReadAction","target":["https:\/\/www.silicloud.com\/zh\/blog\/%e4%bd%bf%e7%94%a8nifi-http%e5%a4%84%e7%90%86%e5%99%a8%e6%9d%a5%e8%8e%b7%e5%8f%96%e5%b9%b6%e8%a7%a3%e5%8e%8b%e6%96%87%e4%bb%b6%ef%bc%8c%e7%84%b6%e5%90%8e%e5%b0%86%e6%8c%87%e5%ae%9a%e6%a8%a1%e5%bc%8f\/"]}]},{"@type":"BreadcrumbList","@id":"https:\/\/www.silicloud.com\/zh\/blog\/%e4%bd%bf%e7%94%a8nifi-http%e5%a4%84%e7%90%86%e5%99%a8%e6%9d%a5%e8%8e%b7%e5%8f%96%e5%b9%b6%e8%a7%a3%e5%8e%8b%e6%96%87%e4%bb%b6%ef%bc%8c%e7%84%b6%e5%90%8e%e5%b0%86%e6%8c%87%e5%ae%9a%e6%a8%a1%e5%bc%8f\/#breadcrumb","itemListElement":[{"@type":"ListItem","position":1,"name":"\u9996\u9875","item":"https:\/\/www.silicloud.com\/zh\/blog\/"},{"@type":"ListItem","position":2,"name":"\u4f7f\u7528NiFi HTTP\u5904\u7406\u5668\u6765\u83b7\u53d6\u5e76\u89e3\u538b\u6587\u4ef6\uff0c\u7136\u540e\u5c06\u6307\u5b9a\u6a21\u5f0f\u7684\u6587\u4ef6\u6574\u7406\u540e\u53d1\u9001\u5230Kafka"}]},{"@type":"WebSite","@id":"https:\/\/www.silicloud.com\/zh\/blog\/#website","url":"https:\/\/www.silicloud.com\/zh\/blog\/","name":"Blog - Silicon Cloud","description":"","inLanguage":"zh-Hans"},{"@type":"Person","@id":"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/6530331a63adef3b3443a1fab53a0e6e","name":"\u97f5, \u79d1","image":{"@type":"ImageObject","inLanguage":"zh-Hans","@id":"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/image\/","url":"https:\/\/secure.gravatar.com\/avatar\/429ccb39b3fff5188bc17986222cfb0936cbadb8cc933cff04ab5ca01bd30a08?s=96&d=mm&r=g","contentUrl":"https:\/\/secure.gravatar.com\/avatar\/429ccb39b3fff5188bc17986222cfb0936cbadb8cc933cff04ab5ca01bd30a08?s=96&d=mm&r=g","caption":"\u97f5, \u79d1"},"url":"https:\/\/www.silicloud.com\/zh\/blog\/author\/yunke\/"},{"@type":"ImageObject","inLanguage":"zh-Hans","@id":"https:\/\/www.silicloud.com\/zh\/blog\/%e4%bd%bf%e7%94%a8nifi-http%e5%a4%84%e7%90%86%e5%99%a8%e6%9d%a5%e8%8e%b7%e5%8f%96%e5%b9%b6%e8%a7%a3%e5%8e%8b%e6%96%87%e4%bb%b6%ef%bc%8c%e7%84%b6%e5%90%8e%e5%b0%86%e6%8c%87%e5%ae%9a%e6%a8%a1%e5%bc%8f\/#local-main-organization-logo","url":"","contentUrl":"","caption":"Blog - Silicon Cloud"}]}},"_links":{"self":[{"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/posts\/47119","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/users\/3"}],"replies":[{"embeddable":true,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/comments?post=47119"}],"version-history":[{"count":2,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/posts\/47119\/revisions"}],"predecessor-version":[{"id":91256,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/posts\/47119\/revisions\/91256"}],"wp:attachment":[{"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/media?parent=47119"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/categories?post=47119"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/tags?post=47119"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}