Es konnten keine Appender für den Logger gefunden werden (org.apache.kafka.clients.consumer.ConsumerConfig)

Question

Ich versuche Apache Kafka mit Apache Flink zu verbinden, indem ich einen Kafka Consumer in Scala erstelle. Das ist mein Consumer-Code:

val properties = new Properties() 
properties.setProperty("bootstrap.servers", "localhost:9092") 
properties.setProperty("zookeeper.connect", "localhost:2181") 
properties.setProperty("group.id", "test") 

val env = StreamExecutionEnvironment.getExecutionEnvironment 
val stream = env 
      .addSource(new FlinkKafkaConsumer09[String]("test", new SimpleStringSchema(), properties)) 
      .print 
env.enableCheckpointing(5000) 

Als ich dieses Programm ausführen ich einige Warnungen von log4j erhalten und das Programm beendet wird, wird keine Ausgabe angezeigt. Mein Kafka Producer ist betriebsbereit.

log4j:WARN No appenders could be found for logger (org.apache.kafka.clients.consumer.ConsumerConfig). 
log4j:WARN Please initialize the log4j system properly. 
log4j:WARN See http://logging.apache.org/log4j/1.2/faq.html#noconfig for more info. 

Answer 1

Ich glaube nicht, dass der log4j WARN der Grund für das Programm Beendigung ist. Diese Probleme treten normalerweise auf, wenn log4j im Klassenpfad nicht verfügbar ist.

Der Grund, warum keine Ausgabe produziert wird, ist, weil der env.execute() Aufruf fehlt, so dass der Job nie gestartet wird.