logstash配置文件到kafka，kafka接收不到数据

input {
file { path => "/var/log/172.16.16.121.log" } }
filter { }
output { kafka { bootstrap_servers => "172.16.16.120:9092" topic_id => "test_SSA1" compression_type => "snappy" } }

先自己发一些消息到这个topic看看kafka是不是正常的，然后看看是不是要把bootstrap_servers 改成zk的地址