diff --git a/installer/conf/kube.conf b/installer/conf/kube.conf
index 164865022..d0ef0517d 100644
--- a/installer/conf/kube.conf
+++ b/installer/conf/kube.conf
@@ -119,8 +119,8 @@
       max_retry_wait 9m
      </match>
 
-     <match oms.api.ContainerNodeInventory**>
-      type out_oms_api
+     <match oms.containerinsights.ContainerNodeInventory**>
+      type out_oms
       log_level debug
       buffer_chunk_limit 20m
       buffer_type file
diff --git a/source/code/plugin/in_kube_nodes.rb b/source/code/plugin/in_kube_nodes.rb
index a6908fc99..2e48e3f1f 100644
--- a/source/code/plugin/in_kube_nodes.rb
+++ b/source/code/plugin/in_kube_nodes.rb
@@ -6,7 +6,7 @@ module Fluent
     class Kube_nodeInventory_Input < Input
       Plugin.register_input('kubenodeinventory', self)
   
-      @@ContainerNodeInventoryTag = 'oms.api.ContainerNodeInventory'
+      @@ContainerNodeInventoryTag = 'oms.containerinsights.ContainerNodeInventory'
 
       def initialize
         super
@@ -109,7 +109,12 @@ def enumerate
                     dockerVersion.slice! "docker://"
                     containerNodeInventoryRecord['DockerVersion'] = dockerVersion
                     # ContainerNodeInventory data for docker version and operating system.
-                    containerNodeInventoryEventStream.add(emitTime, containerNodeInventoryRecord) if containerNodeInventoryRecord
+                    containerNodeInventoryWrapper = {
+                      "DataType"=>"CONTAINER_NODE_INVENTORY_BLOB",
+                      "IPName"=>"ContainerInsights",
+                      "DataItems"=>[containerNodeInventoryRecord.each{|k,v| containerNodeInventoryRecord[k]=v}]
+                    }
+                    containerNodeInventoryEventStream.add(emitTime, containerNodeInventoryWrapper) if containerNodeInventoryWrapper
 
                     wrapper = {
                       "DataType"=>"KUBE_NODE_INVENTORY_BLOB",