diff --git a/pulsar/internal/connection.go b/pulsar/internal/connection.go
index c246308d6..04a3cc83f 100644
--- a/pulsar/internal/connection.go
+++ b/pulsar/internal/connection.go
@@ -625,10 +625,6 @@ func (c *connection) checkServerError(err *pb.ServerError) {
 	}
 }
 
-func (c *connection) Write(data Buffer) {
-	c.writeRequestsCh <- data
-}
-
 func (c *connection) SendRequest(requestID uint64, req *pb.BaseCommand,
 	callback func(command *pb.BaseCommand, err error)) {
 	c.incomingRequestsWG.Add(1)
diff --git a/pulsar/internal/connection_reader.go b/pulsar/internal/connection_reader.go
index c451562c0..c2541f68c 100644
--- a/pulsar/internal/connection_reader.go
+++ b/pulsar/internal/connection_reader.go
@@ -18,7 +18,6 @@
 package internal
 
 import (
-	"bufio"
 	"fmt"
 	"io"
 
@@ -29,13 +28,11 @@ import (
 type connectionReader struct {
 	cnx    *connection
 	buffer Buffer
-	reader *bufio.Reader
 }
 
 func newConnectionReader(cnx *connection) *connectionReader {
 	return &connectionReader{
 		cnx:    cnx,
-		reader: bufio.NewReader(cnx.cnx),
 		buffer: NewBuffer(4096),
 	}
 }