Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id 63911200D18 for ; Wed, 11 Oct 2017 10:47:50 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id 5FF2D1609E4; Wed, 11 Oct 2017 08:47:50 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id A65261609CA for ; Wed, 11 Oct 2017 10:47:49 +0200 (CEST) Received: (qmail 78691 invoked by uid 500); 11 Oct 2017 08:47:48 -0000 Mailing-List: contact dev-help@flink.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@flink.apache.org Delivered-To: mailing list dev@flink.apache.org Received: (qmail 78680 invoked by uid 99); 11 Oct 2017 08:47:48 -0000 Received: from mail-relay.apache.org (HELO mail-relay.apache.org) (140.211.11.15) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 11 Oct 2017 08:47:48 +0000 Received: from [192.168.178.53] (ip-2-205-81-99.web.vodafone.de [2.205.81.99]) by mail-relay.apache.org (ASF Mail Server at mail-relay.apache.org) with ESMTPSA id 0C3E71A02CD for ; Wed, 11 Oct 2017 08:47:47 +0000 (UTC) Subject: Re: Not being able to log from Flink to Kafka To: dev@flink.apache.org References: From: Chesnay Schepler Message-ID: <57f3eb1e-43d9-40d5-7232-08cf54aa8c75@apache.org> Date: Wed, 11 Oct 2017 10:47:48 +0200 User-Agent: Mozilla/5.0 (Windows NT 10.0; WOW64; rv:52.0) Gecko/20100101 Thunderbird/52.2.1 MIME-Version: 1.0 In-Reply-To: Content-Type: text/plain; charset=utf-8; format=flowed Content-Transfer-Encoding: 7bit Content-Language: en-US archived-at: Wed, 11 Oct 2017 08:47:50 -0000 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. but > everytime ran it said: > > 10/10/2017 10:30:00 AM - log4j:ERROR Could not instantiate class > [org.apache.kafka.log4jappender.KafkaLog4jAppender]. > 10/10/2017 10:30:00 AM - java.lang.ClassNotFoundException: > org.apache.kafka.log4jappender.KafkaLog4jAppender > 10/10/2017 10:30:00 AM - at > java.net.URLClassLoader.findClass(URLClassLoader.java:381) > 10/10/2017 10:30:00 AM - at > java.lang.ClassLoader.loadClass(ClassLoader.java:424) > 10/10/2017 10:30:00 AM - at > sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:331) > 10/10/2017 10:30:00 AM - at > java.lang.ClassLoader.loadClass(ClassLoader.java:357) > 10/10/2017 10:30:00 AM - at java.lang.Class.forName0(Native Method) > 10/10/2017 10:30:00 AM - at java.lang.Class.forName(Class.java:264) > 10/10/2017 10:30:00 AM - at > org.apache.log4j.helpers.Loader.loadClass(Loader.java:198) > 10/10/2017 10:30:00 AM - at > org.apache.log4j.helpers.OptionConverter.instantiateByClassName(OptionConverter.java:327) > 10/10/2017 10:30:00 AM - at > org.apache.log4j.helpers.OptionConverter.instantiateByKey(OptionConverter.java:124) > 10/10/2017 10:30:00 AM - at > org.apache.log4j.PropertyConfigurator.parseAppender(PropertyConfigurator.java:785) > 10/10/2017 10:30:00 AM - at > org.apache.log4j.PropertyConfigurator.parseCategory(PropertyConfigurator.java:768) > 10/10/2017 10:30:00 AM - at > org.apache.log4j.PropertyConfigurator.configureRootCategory(PropertyConfigurator.java:648) > 10/10/2017 10:30:00 AM - at > org.apache.log4j.PropertyConfigurator.doConfigure(PropertyConfigurator.java:514) > 10/10/2017 10:30:00 AM - at > org.apache.log4j.PropertyConfigurator.doConfigure(PropertyConfigurator.java:580) > 10/10/2017 10:30:00 AM - at > org.apache.log4j.helpers.OptionConverter.selectAndConfigure(OptionConverter.java:526) > 10/10/2017 10:30:00 AM - at > org.apache.log4j.LogManager.(LogManager.java:127) > 10/10/2017 10:30:00 AM - at > org.slf4j.impl.Log4jLoggerFactory.getLogger(Log4jLoggerFactory.java:64) > 10/10/2017 10:30:00 AM - at > org.slf4j.LoggerFactory.getLogger(LoggerFactory.java:277) > 10/10/2017 10:30:00 AM - at > org.slf4j.LoggerFactory.getLogger(LoggerFactory.java:288) > 10/10/2017 10:30:00 AM - at > org.apache.flink.client.CliFrontend.(CliFrontend.java:107) > 10/10/2017 10:30:00 AM - log4j:ERROR Could not instantiate appender > named "kafka". > > > The classpath have the jar for the kafka classes but for some reason > it not being able to use it. > > I really appreciate some help > > Jose >