找不到记录器的附加程序 (org.apache.kafka.clients.consumer.ConsumerConfig)

Question

我正在尝试通过在 Scala 中创建 Kafka Consumer 将 Apache Kafka 连接到 Apache Flink。这是我的消费者代码：

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 收到一些警告并且程序终止，没有显示输出。我的 Kafka Producer 已启动运行ning。

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() 调用，所以作业从未启动。

找不到记录器的附加程序 (org.apache.kafka.clients.consumer.ConsumerConfig)

No appenders could be found for logger (org.apache.kafka.clients.consumer.ConsumerConfig)

log4j

scala

apache-kafka

apache-flink