Merge pull request #254 from sematext/hotfix-k8s-enrichment-dropping-…

…logs
sematext · Sep 1, 2020 · bef4577 · bef4577
2 parents e76ffe4 + 97e2fb6
commit bef4577
Showing 1 changed file with 7 additions and 2 deletions.
diff --git a/lib/plugins/output-filter/kubernetes-enrichment.js b/lib/plugins/output-filter/kubernetes-enrichment.js
@@ -49,13 +49,13 @@ function kubernetesOutputFilter (
 ) {
   // we use the config object to track state of each plugin instance
   if (!config.client) {
-    initKubernetesClient(config)
+    initKubernetesClient(context, config, eventEmitter, data, callback)
   } else {
     enrichLogs(context, config, eventEmitter, data, callback)
   }
 }
 
-function initKubernetesClient (config) {
+function initKubernetesClient (context, config, eventEmitter, data, callback) {
   // do we run in k8s cluster?
   config.client = client
   config.getPodSpec = function (namespace, podName, cb) {
@@ -64,6 +64,8 @@ function initKubernetesClient (config) {
       .pods(podName)
       .get(cb)
   }.bind(config)
+
+  enrichLogs(context, config, eventEmitter, data, callback)
 }
 
 const getPodSpec = async (config, namespace, podName, cb) => {
@@ -216,6 +218,9 @@ function processAnnotations (
     checkLogsReceiverUrl(pod, data, context)
     return callback(null, data)
   }
+
+  // fallback to return data if no pod info found
+  return callback(null, data)
 }
 
 function getPodCacheKey (data) {