server: better logs

travisjeffery · Sep 3, 2017 · e7c94f6 · e7c94f6
1 parent a2fd23a
commit e7c94f6
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/server/server.go b/server/server.go
@@ -134,7 +134,7 @@ func (s *Server) handleRequest(conn net.Conn) {
 
 		d := protocol.NewDecoder(b)
 		header.Decode(d)
-		s.logger.Debug("correlation id [%d], request size [%d], key [%d]", header.CorrelationID, size, header.APIKey)
+		s.logger.Debug("request: correlation id [%d], client id [%s], request size [%d], key [%d]", header.CorrelationID, header.ClientID, size, header.APIKey)
 
 		switch header.APIKey {
 		case protocol.APIVersionsKey:
@@ -401,6 +401,7 @@ func (s *Server) handleMetadata(conn net.Conn, header *protocol.RequestHeader, r
 }
 
 func (s *Server) write(conn net.Conn, header *protocol.RequestHeader, e protocol.Encoder) error {
+	s.logger.Debug("response: correlation id [%d], key [%d]", header.CorrelationID, header.APIKey)
 	b, err := protocol.Encode(e)
 	if err != nil {
 		return err