Kaydedici için ekleyiciler bulunamadı (org.apache.kafka.clients.consumer.ConsumerConfig)

Question

Scala'da Kafka Tüketicisi oluşturarak Apache Kafka'yı Apache Flink'e bağlamaya çalışıyorum.

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) 

ben log4j bazı uyarıları almak bu programı çalıştırın ve programı sonlandırır, hiçbir çıkış gösterilmiştir: Bu benim Tüketici kodudur. Kafka Yapımcım çalışıyor ve çalışıyor.

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'in program sonlandırmasının nedeni olduğunu sanmıyorum. Bu sorunlar, genellikle class4j sınıf yolunda mevcut olmadığında oluşur.

env.execute() çağrısının eksik olması nedeniyle çıkış üretilmemesinin nedeni, işin hiçbir zaman başlatılmamasıdır.