feat: expose kafka stream

ayZagen · Apr 10, 2021 · a1a0e2f · a1a0e2f
1 parent a7584c1
commit a1a0e2f
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/pkafka.js b/pkafka.js
@@ -72,6 +72,8 @@ module.exports = function pinoKafka(opts) {
 
   inputStream.pipe(through)
 
+  through._kafka = kafkaStream
+
   return through;
 }