It looks like you have another process running for kafka broker. Stop that broker and start a new one.
-- Harsha On May 24, 2015 at 11:05:27 PM, Sanjay Mistry (mistrysanja...@gmail.com) wrote: Hello, When run this command "bin/kafka-console-producer.sh --broker-list localhost:9092 --topic testing". i am getting "INFO Closing socket connection to /127.0.0.1. (kafka.network.Processor)" error in server konsol. Please help me. On Sat, May 23, 2015 at 12:19 PM, Sanjay Mistry <mistrysanja...@gmail.com> wrote: > [2015-05-23 12:16:41,624] INFO Initiating client connection, > connectString=localhost:2181 sessionTimeout=6000 > watcher=org.I0Itec.zkclient.ZkClient@70808f4e > (org.apache.zookeeper.ZooKeeper) > [2015-05-23 12:16:41,659] INFO Opening socket connection to server > localhost/0:0:0:0:0:0:0:1:2181 (org.apache.zookeeper.ClientCnxn) > [2015-05-23 12:16:41,673] INFO Socket connection established to > localhost/0:0:0:0:0:0:0:1:2181, initiating session > (org.apache.zookeeper.ClientCnxn) > [2015-05-23 12:16:41,740] INFO Session establishment complete on server > localhost/0:0:0:0:0:0:0:1:2181, sessionid = 0x14d7f85f7a30000, negotiated > timeout = 6000 (org.apache.zookeeper.ClientCnxn) > [2015-05-23 12:16:41,743] INFO zookeeper state changed (SyncConnected) > (org.I0Itec.zkclient.ZkClient) > [2015-05-23 12:16:42,015] FATAL Fatal error during KafkaServerStable > startup. Prepare to shutdown (kafka.server.KafkaServerStartable) > kafka.common.KafkaException: Failed to acquire lock on file .lock in > /tmp/kafka-logs. A Kafka instance in another process or thread is using > this directory. > at > kafka.log.LogManager$$anonfun$lockLogDirs$1.apply(LogManager.scala:95) > at > kafka.log.LogManager$$anonfun$lockLogDirs$1.apply(LogManager.scala:92) > at > scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) > > at > scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) > > at > scala.collection.IndexedSeqOptimized$class.foreach(IndexedSeqOptimized.scala:34) > > at > scala.collection.mutable.WrappedArray.foreach(WrappedArray.scala:33) > at > scala.collection.TraversableLike$class.map(TraversableLike.scala:233) > at scala.collection.mutable.WrappedArray.map(WrappedArray.scala:33) > at kafka.log.LogManager.lockLogDirs(LogManager.scala:92) > at kafka.log.LogManager.<init>(LogManager.scala:55) > at kafka.server.KafkaServer.createLogManager(KafkaServer.scala:275) > at kafka.server.KafkaServer.startup(KafkaServer.scala:72) > at > kafka.server.KafkaServerStartable.startup(KafkaServerStartable.scala:34) > at kafka.Kafka$.main(Kafka.scala:46) > at kafka.Kafka.main(Kafka.scala) > [2015-05-23 12:16:42,023] INFO [Kafka Server 0], shutting down > (kafka.server.KafkaServer) > [2015-05-23 12:16:42,030] INFO Terminate ZkClient event thread. > (org.I0Itec.zkclient.ZkEventThread) > [2015-05-23 12:16:42,036] INFO EventThread shut down > (org.apache.zookeeper.ClientCnxn) > [2015-05-23 12:16:42,037] INFO Session: 0x14d7f85f7a30000 closed > (org.apache.zookeeper.ZooKeeper) > [2015-05-23 12:16:42,038] INFO [Kafka Server 0], shut down completed > (kafka.server.KafkaServer) > [2015-05-23 12:16:42,040] INFO [Kafka Server 0], shutting down > (kafka.server.KafkaServer) > >
