diff --git a/pkafka.js b/pkafka.js
index 898303a..ca8ec80 100644
--- a/pkafka.js
+++ b/pkafka.js
@@ -72,6 +72,8 @@ module.exports = function pinoKafka(opts) {
 
   inputStream.pipe(through)
 
+  through._kafka = kafkaStream
+
   return through;
 }