rsyslog가 kafka에 로그를 쓰지 않습니다.

Question

저는 rsyslog 및 kafka에 익숙하며 다음 로그 스트림을 얻으려고 할 때 약간의 문제가 있습니다. 여기

nginx log -> rsyslog-imudp -> rsyslog-omkafka -> kafka 

나는 그것이이다

bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic rsyslog_logstash --from-beginning 

어쩌면 소비자 터미널에서 모든 출력이없는 불길

module(load="imudp") 
input(type="imudp" port="514") 

module(load="omkafka") 

template(name="nginxLog" type="string" string="%msg%") 

if $inputname == "imudp"then { 
     action(type="omkafka" 
      template="nginxLog" 
      broker=["localhost:9092"] 
      topic="rsyslog_logstash" 
      partitions.auto="on" 
      confParam=[ 
       "socket.keepalive.enable=true" 
      ] 
     ) 
} 

의 nginx conf의

log_format jsonlog '{' 
    '"host": "$host",' 
    '"server_addr": "$server_addr",' 
    '"http_x_forwarded_for":"$http_x_forwarded_for",' 
    '"remote_addr":"$remote_addr",' 
    '"time_local":"$time_local",' 
    '"request_method":"$request_method",' 
    '"request_uri":"$request_uri",' 
    '"status":$status,' 
    '"body_bytes_sent":$body_bytes_sent,' 
    '"http_referer":"$http_referer",' 
    '"http_user_agent":"$http_user_agent",' 
    '"upstream_addr":"$upstream_addr",' 
    '"upstream_status":"$upstream_status",' 
    '"upstream_response_time":"$upstream_response_time",' 
    '"request_time":$request_time' 
'}'; 

access_log syslog:server=server_ip,facility=local7,tag=nginx_access_log jsonlog; 

그리고 위해 rsyslog의 conf입니다 템플릿을 찾았지만 m을 찾을 수 없습니다. 그것에 관한 uch 문서.

Answer 1

imsp를받은 메시지 수와 omkafka로 보낸 메시지 수를 확인하는 rsyslog-impstats 모듈을 사용하십시오.