I kafka-Kunden-0.9.0.0.jar mit Maven heruntergeladen und ich erwarte ich Kafka LoggingSo aktivieren Kafka mit log4j Logging
Allerdings habe ich keine Ahnung, in dieser Verbindung, wie die Protokollierung würde, warum ich nicht immer jede Protokollierung, sogar ich habe die bootstrap.server falsch auf purpuse gesetzt, aber es blieb einfach stecken, ohne irgendeine Warnung zu werfen. Ich habe ein paar Zeilen Code hinzugefügt, um mit Log4j in eine Datei zu drucken, und es scheint Arbeit, aber keine Ahnung, warum Kafka Ereignis zu Log4j nicht protokollieren kann.
import org.apache.log4j.Logger;
public class ConsumerLoop implements Runnable {
final static Logger logger = Logger.getLogger(ConsumerLoop.class);
@Override
public void run() {
logger.warn("running!!!!!");
}
}
SLF4J: Failed to load class "org.slf4j.impl.StaticLoggerBinder".
SLF4J: Defaulting to no-operation (NOP) logger implementation
SLF4J: See http://www.slf4j.org/codes.html#StaticLoggerBinder for further details.
2016-04-04 12:54:01 WARN ConsumerLoop:40 - running!!!!!
Hinweis gibt es slf4j-api-1.7.6.jar, die als Abhängigkeit von kafka kam. Sogar ich habe die erforderliche Bibliothek slf4j-api-x.x.x.jar, slf4j-log4jx-x.x.x.jar und verwendet slf4j, um sogar zu protokollieren, aber immer noch nicht die Kafka-Protokolle zu erhalten.