Fix usage of steam, added logging of json errors (#88)

pinojs · Jul 4, 2021 · f152b7f · f152b7f
1 parent ab54e60
commit f152b7f
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/cli.js b/cli.js
@@ -35,6 +35,9 @@ function start (opts) {
 
   const stream = pinoElasticSearch(opts)
 
+  stream.on('unknown', (line, error) => {
+    console.error('Elasticsearch client json error in line:\n' + line + '\nError:', error)
+  })
   stream.on('error', (error) => {
     console.error('Elasticsearch client error:', error)
   })
@@ -45,7 +48,7 @@ function start (opts) {
   if (opts.rejectUnauthorized) {
     opts.rejectUnauthorized = opts.rejectUnauthorized !== 'false'
   }
-  pump(process.stdin, pinoElasticSearch(opts))
+  pump(process.stdin, stream)
 }
 
 const flags = minimist(process.argv.slice(2), {