logger（org.apache.kafka.clients.consumer.ConsumerConfig）のアペンダーが見つかりません

Question

私は、ScalaでKafka Consumerを作成してApache FlinkにApache Kafkaを接続しようとしています。

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) 

私はlog4jのからいくつかの警告を取得し、このプログラムを実行するとプログラムが終了すると、何も出力が示されていない：これは私の消費者のコードです。私のカフカプロデューサーが立ち上がっています。

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

私はlog4j WARNがプログラム終了の理由ではないと思います。 これらの問題は通常、log4jがクラスパスで使用できない場合に発生します。

出力が生成されない理由は、env.execute()コールが欠落しているためにジョブが開始されないためです。