Re: Not being able to log from Flink to Kafka

2017-10-11 Thread Chesnay Schepler
Is the KafkaLog4jAppender in the user-jar, or in the /lib directory of the flink distribution? On 10.10.2017 22:36, Jose Gonzalez Torres wrote: Hi Guys I am trying to use log4j to log all the info from my Flink Application into a Kafka Topic. The Flink application is running in cluster mode. b

Not being able to log from Flink to Kafka

2017-10-10 Thread Jose Gonzalez Torres
Hi Guys I am trying to use log4j to log all the info from my Flink Application into a Kafka Topic. The Flink application is running in cluster mode. but everytime ran it said: 10/10/2017 10:30:00 AM - log4j:ERROR Could not instantiate class [org.apache.kafka.log4jappender.KafkaLog4jAppender]. 10/