Actually, our default ZK port is 2181, not 2180. Could you try the following setting?
log4j.appender.KAFKA.zkConnect=127.0.0.1:218 <http://127.0.0.1:2180/>1 Thanks, Jun On Wed, Aug 7, 2013 at 2:13 AM, sphinx jiang <yishan...@gmail.com> wrote: > Sorry, didn't find what should be set from the start page. > > Here is the newest setting(with brokerlist): > log4j.appender.KAFKA=kafka.producer.KafkaLog4jAppender > log4j.appender.KAFKA.zkConnect=127.0.0.1:2180 > log4j.appender.KAFKA.BrokerList=0:localhost:9092 > log4j.appender.KAFKA.SerializerClass=kafka.serializer.StringEncoder > log4j.appender.KAFKA.Topic= 1650 > log4j.logger.com.test.kafka.examples = INFO, KAFKA > > and here is the outcoming: > > log4j:WARN No appenders could be found for logger > (org.I0Itec.zkclient.ZkEventThread). > log4j:WARN Please initialize the log4j system properly. > Exception in thread "main" java.lang.ExceptionInInitializerError > at java.lang.J9VMInternals.initialize(J9VMInternals.java:222) > at org.apache.log4j.Logger.getLogger(Logger.java:118) > at org.I0Itec.zkclient.ZkClient.<clinit>(ZkClient.java:57) > at java.lang.J9VMInternals.initializeImpl(Native Method) > at java.lang.J9VMInternals.initialize(J9VMInternals.java:200) > at > kafka.producer.ZKBrokerPartitionInfo.<init>(ZKBrokerPartitionInfo.scala:62) > at kafka.producer.Producer.<init>(Producer.scala:47) > at kafka.javaapi.producer.Producer.<init>(Producer.scala:33) > at kafka.javaapi.producer.Producer.<init>(Producer.scala:40) > at com.test.kafka.examples.Producer.<init>(Producer.java:46) > at > > com.test.kafka.examples.SimpleConsumerDemo.generateData(SimpleConsumerDemo.java:40) > at > com.test.kafka.examples.SimpleConsumerDemo.main(SimpleConsumerDemo.java:57) > Caused by: java.lang.NullPointerException > at org.I0Itec.zkclient.ZkClient.close(ZkClient.java:915) > at org.I0Itec.zkclient.ZkClient.connect(ZkClient.java:888) > at org.I0Itec.zkclient.ZkClient.<init>(ZkClient.java:98) > at org.I0Itec.zkclient.ZkClient.<init>(ZkClient.java:84) > at > kafka.producer.ZKBrokerPartitionInfo.<init>(ZKBrokerPartitionInfo.scala:62) > at kafka.producer.Producer.<init>(Producer.scala:47) > at kafka.producer.Producer.<init>(Producer.scala:63) > at > > kafka.producer.KafkaLog4jAppender.activateOptions(KafkaLog4jAppender.scala:70) > at org.apache.log4j.config.PropertySetter.activate(PropertySetter.java:257) > at > > org.apache.log4j.config.PropertySetter.setProperties(PropertySetter.java:133) > at > > org.apache.log4j.config.PropertySetter.setProperties(PropertySetter.java:97) > at > > org.apache.log4j.PropertyConfigurator.parseAppender(PropertyConfigurator.java:689) > at > > org.apache.log4j.PropertyConfigurator.parseCategory(PropertyConfigurator.java:647) > at > > org.apache.log4j.PropertyConfigurator.parseCatsAndRenderers(PropertyConfigurator.java:568) > at > > org.apache.log4j.PropertyConfigurator.doConfigure(PropertyConfigurator.java:442) > at > > org.apache.log4j.PropertyConfigurator.doConfigure(PropertyConfigurator.java:476) > at > > org.apache.log4j.helpers.OptionConverter.selectAndConfigure(OptionConverter.java:471) > at org.apache.log4j.LogManager.<clinit>(LogManager.java:125) > at java.lang.J9VMInternals.initializeImpl(Native Method) > at java.lang.J9VMInternals.initialize(J9VMInternals.java:200) > ... 11 more > > > > > 2013/8/7 Jun Rao <jun...@gmail.com> > > > Could you try just setting brokerlist? > > > > Thanks, > > > > Jun > > > > > > On Tue, Aug 6, 2013 at 5:34 AM, sphinx jiang <yishan...@gmail.com> > wrote: > > > > > Hi, I am learning kafka 0.7 this days, with a single node, :) > > > > > > When I run the example code, I defining the Kafka appender in my > > > log4j.properties like the kafka apache quickstart page told. > > > > > > log4j.appender.KAFKA = kafka.producer.KafkaLog4jAppender > > > log4j.appender.KAFKA.Host = localhost > > > log4j.appender.KAFKA.SerializerClass = > > kafka.test.AppenderStringSerializer > > > log4j.appender.KAFKA.Port = 9092 > > > log4j.appender.KAFKA.Topic = test > > > log4j.logger.com.test.kafka.examples = INFO, KAFKA > > > > > > But then I met the following problems: > > > > > > log4j:WARN No such property [port] in > kafka.producer.KafkaLog4jAppender. > > > log4j:WARN No such property [host] in > kafka.producer.KafkaLog4jAppender. > > > Exception in thread "main" java.lang.ExceptionInInitializerError > > > at java.lang.J9VMInternals.initialize(J9VMInternals.java:222) > > > at org.apache.log4j.Logger.getLogger(Logger.java:118) > > > at org.I0Itec.zkclient.ZkClient.<clinit>(ZkClient.java:57) > > > at java.lang.J9VMInternals.initializeImpl(Native Method) > > > at java.lang.J9VMInternals.initialize(J9VMInternals.java:200) > > > at > > > > > > kafka.producer.ZKBrokerPartitionInfo.<init>(ZKBrokerPartitionInfo.scala:62) > > > at kafka.producer.Producer.<init>(Producer.scala:47) > > > at kafka.javaapi.producer.Producer.<init>(Producer.scala:33) > > > at kafka.javaapi.producer.Producer.<init>(Producer.scala:40) > > > at com.test.kafka.examples.Producer.<init>(Producer.java:46) > > > at > > > > > > > > > com.test.kafka.examples.SimpleConsumerDemo.generateData(SimpleConsumerDemo.java:40) > > > at > > > > > > com.test.kafka.examples.SimpleConsumerDemo.main(SimpleConsumerDemo.java:57) > > > Caused by: kafka.producer.async.MissingConfigException: One of these > > > connection properties must be specified: zkConnect, brokerList. > > > at > > > > > > > > > kafka.producer.KafkaLog4jAppender.activateOptions(KafkaLog4jAppender.scala:59) > > > at > > > > org.apache.log4j.config.PropertySetter.activate(PropertySetter.java:257) > > > at > > > > > > > > > org.apache.log4j.config.PropertySetter.setProperties(PropertySetter.java:133) > > > at > > > > > > > > > org.apache.log4j.config.PropertySetter.setProperties(PropertySetter.java:97) > > > at > > > > > > > > > org.apache.log4j.PropertyConfigurator.parseAppender(PropertyConfigurator.java:689) > > > at > > > > > > > > > org.apache.log4j.PropertyConfigurator.parseCategory(PropertyConfigurator.java:647) > > > at > > > > > > > > > org.apache.log4j.PropertyConfigurator.parseCatsAndRenderers(PropertyConfigurator.java:568) > > > at > > > > > > > > > org.apache.log4j.PropertyConfigurator.doConfigure(PropertyConfigurator.java:442) > > > at > > > > > > > > > org.apache.log4j.PropertyConfigurator.doConfigure(PropertyConfigurator.java:476) > > > at > > > > > > > > > org.apache.log4j.helpers.OptionConverter.selectAndConfigure(OptionConverter.java:471) > > > at org.apache.log4j.LogManager.<clinit>(LogManager.java:125) > > > > > > In the source code, there are port and host property, and I add the > > > zkConnect, brokerList. > > > log4j.appender.KAFKA.zkConnect =localhost:2181 > > > log4j.appender.KAFKA.brokerList = localhost:9092 > > > > > > There are still problems here. > > > > > > log4j:WARN Using default encoder - kafka.serializer.StringEncoder > > > log4j:WARN No appenders could be found for logger > > > (org.I0Itec.zkclient.ZkEventThread). > > > log4j:WARN Please initialize the log4j system properly. > > > Exception in thread "main" java.lang.ExceptionInInitializerError > > > at java.lang.J9VMInternals.initialize(J9VMInternals.java:222) > > > at org.apache.log4j.Logger.getLogger(Logger.java:118) > > > at org.I0Itec.zkclient.ZkClient.<clinit>(ZkClient.java:57) > > > at java.lang.J9VMInternals.initializeImpl(Native Method) > > > at java.lang.J9VMInternals.initialize(J9VMInternals.java:200) > > > at > > > > > > kafka.producer.ZKBrokerPartitionInfo.<init>(ZKBrokerPartitionInfo.scala:62) > > > at kafka.producer.Producer.<init>(Producer.scala:47) > > > at kafka.javaapi.producer.Producer.<init>(Producer.scala:33) > > > at kafka.javaapi.producer.Producer.<init>(Producer.scala:40) > > > at com.test.kafka.examples.Producer.<init>(Producer.java:46) > > > at > > > > > > > > > com.test.kafka.examples.SimpleConsumerDemo.generateData(SimpleConsumerDemo.java:40) > > > at > > > > > > com.test.kafka.examples.SimpleConsumerDemo.main(SimpleConsumerDemo.java:57) > > > Caused by: java.lang.NullPointerException > > > at org.I0Itec.zkclient.ZkClient.close(ZkClient.java:915) > > > at org.I0Itec.zkclient.ZkClient.connect(ZkClient.java:888) > > > at org.I0Itec.zkclient.ZkClient.<init>(ZkClient.java:98) > > > at org.I0Itec.zkclient.ZkClient.<init>(ZkClient.java:84) > > > at > > > > > > kafka.producer.ZKBrokerPartitionInfo.<init>(ZKBrokerPartitionInfo.scala:62) > > > at kafka.producer.Producer.<init>(Producer.scala:47) > > > > > > Without the logger appender, the code runs almost right.(Other problems > > > will be metioned in next mail.) > > > > > >
