Kafka 소비자가 과도한 DEBUG 문을 콘솔에 출력합니다.

http://www.javaworld.com/article/3060078/big-data/big-data-messaging-with-kafka-part-1.html?page=2에서 샘플 코드를 실행 중이고 kafkaconsumer가 원하는대로 항목을 소비하고 있지만 모든 폴링 결과로 많은 디버그 로그가 인쇄됩니다 (표준 출력) 나는 싫어.Kafka 소비자가 과도한 DEBUG 문을 콘솔에 출력합니다.

/config/log4j.properties, 특히 log4j.logger.kafka=ERROR, kafkaAppender 설정에서 모든 INFO 및 DEBUG를 ERROR (심지어 grep을 확인해도)로 변경해 보았지만 문제가 지속됩니다. 나는 How to configure logging for Kafka producers?을 언급하고 거기서 해결책을 채택했지만, 아마 상황은 소비자를 위해 다르다?

디버그 메시지의 모든

비슷한 형식이 :

[Thread-0] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - Sending fetch for partitions... to broker... (id: 0 rack: null)

을 10의 비율로 표시되는 모든 초 정도 (1000 투표 인수를 변경하거나 심지어 만이 도움이되지 않습니다, 나는 시도)

전문가의 도움을 받아 주셔서 감사합니다. 미리 감사드립니다!

편집 : 중요한지 확실하지 않지만 이전에 Consumer가 시작되지 않게하는 다른 오류를 해결하기 위해 내 기본 방법에 BasicConfigurator.configure();을 추가했습니다.

출처

2017-05-23 Bay Wei Heng

수다스러운 클래스의 로깅 수준을 수정하면됩니다 (수다스러운 상호 작용). 당신이 log4j.properties에 다음 줄을 추가하여 당신이 단순히 로거의 로그 레벨을 조정할 수 있습니다 org.apache.kafka.clients.consumer.internals.Fetcher에서 발생하는 로그 항목을 참조하여 로그에 있기 때문에 이러한 이름 간격 때문에

log4j.logger.org.apache.kafka.clients.consumer.internals.Fetcher=WARN

... 또는 넓은 잡기 로거 :

# adjusting logging for entire Kafka 
log4j.logger.org.apache.kafka=WARN

희망이

출처

2017-05-23 09:30:09 diginoise

내가 결국 https://stackoverflow.com/questions/1509324/log4j-basic-configuration을 사용하는 데 도움이, 그리고 그 솔루션은보다 일반적인 알고 (모든 클래스에 영향을)하지만, 그쪽으로 특정 솔루션에 대한 nks도! :디 –

Kafka 소비자가 과도한 DEBUG 문을 콘솔에 출력합니다.

답변

관련 문제