diff --git a/lib/logstash/inputs/tcp.rb b/lib/logstash/inputs/tcp.rb
index 7530d82eb..2d3acbb1e 100644
--- a/lib/logstash/inputs/tcp.rb
+++ b/lib/logstash/inputs/tcp.rb
@@ -45,6 +45,7 @@ class LogStash::Inputs::Tcp < LogStash::Inputs::Base
               "@tags" => [@type],
             })
             e.source = "tcp://#{@host}:#{@port}/client/#{peer}"
+            @logger.debug(["Received message from #{peer}"], e)
             output_queue << e
           end # loop do
         rescue