Comment configurer la journalisation pour Kafka producteurs?

Je suis à l'aide de Kafka producteur client et je n'ai pas de configuration log4j dans mon projet.

Sur l'exécution, le programme imprime beaucoup de Kafka journaux de Débogage qui je ne veux vraiment pas.

Donc, j'ai essayé d'ajouter un log4j.propriétés pour définir le niveau de journal d'ERREUR comme ci-dessous, qui ne semble pas fonctionner:

log4j.rootLogger=ERROR

Comment puis-je changer Kafka Niveau de Journal?

OriginalL'auteur nikel | 2016-03-03

  1. 8

    Utiliser l'option de ligne de commande -Dlog4j.configuration=file:/path/to/log4j.properties lors de l'exécution de votre client.

    Exemple log4j propriété des fichiers:

    Pour miroir maker et d'autres outils de la suite d'un appel kafka-run-class.sh, vous pouvez utiliser la variable env KAFKA_LOG4J_OPTS (défini comme -Dlog4j.configuration=file:/path/to/log4j.properties) pour modifier la configuration de la journalisation. Voir: https://github.com/apache/kafka/blob/0.10.2/bin/kafka-run-class.sh#L158

    Exemple de mon log4j.properties fichier pour miroir maker que j'utilise pour les tests.

    # https://github.com/apache/kafka/blob/trunk/config/tools-log4j.properties

log4j.rootLogger=DEBUG, stderr

log4j.appender.stderr=org.apache.log4j.ConsoleAppender
log4j.appender.stderr.layout=org.apache.log4j.PatternLayout
log4j.appender.stderr.layout.ConversionPattern=[%d] %p %m (%c)%n
log4j.appender.stderr.Target=System.err

    OriginalL'auteur turtlemonvh

  2. 2

    Essayez d'ajouter de l'exploitation forestière.niveau.org.apache.kafka: DEBUG dans vos clients propriétés de configuration.
    Je suis à l'aide de Springboot et c'est le format. L'utilisation du format approprié pour vos clients programme.

    Cannot set level: WARNING for 'org.apache.kafka' des idées?

    OriginalL'auteur sivakadi

  3. 0

    Je suppose que vous parliez de Kafka journaux du serveur. Vous pouvez modifier le niveau de journal d'ERREUR à l'aide de configuration suivants

    log4j.logger.kafka=ERROR, kafkaAppender

    Espérons que cette aide!

    Je suis en train de combat les journaux qui viennent dans mon programme client..pas le kafka serveur en tant que tel...

    OriginalL'auteur avr

  4. 0
    org.apache.log4j.Logger.getLogger("org").setLevel(Level.WARN);
org.apache.log4j.Logger.getLogger("akka").setLevel(Level.WARN);
org.apache.log4j.Logger.getLogger("kafka").setLevel(Level.WARN);

    OriginalL'auteur tjeubaoit