[2017-11-01 20:39:24,239] INFO Client environment:java.io.tmpdir=C:\Users\Kedar\AppData\Local\Temp\ (org.apache.zookeeper.ZooKeeper) [2017-11-01 20:39:24,239] INFO Client environment:java.compiler= (org.apache.zookeeper.ZooKeeper) [2017-11-01 20:39:24,239] INFO Client environment:os.name=Windows 10 (org.apache.zookeeper.ZooKeeper) [2017-11-01 20:39:24,239] INFO Client environment:os.arch=amd64 (org.apache.zookeeper.ZooKeeper) [2017-11-01 20:39:24,239] INFO Client environment:os.version=10.0 (org.apache.zookeeper.ZooKeeper) [2017-11-01 20:39:24,239] INFO Client environment:user.name=Kedar (org.apache.zookeeper.ZooKeeper) [2017-11-01 20:39:24,239] INFO Client environment:user.home=C:\Users\Kedar (org.apache.zookeeper.ZooKeeper) [2017-11-01 20:39:24,239] INFO Client environment:user.dir=D:\LocationGuru\Servers\Kafka (org.apache.zookeeper.ZooKeeper) [2017-11-01 20:39:24,239] INFO Initiating client connection, connectString=localhost:2181 sessionTimeout=6000 watcher=org.I0Itec.zkclient.ZkClient@363ee3a2 (org.apache.zookeeper.ZooKeeper) [2017-11-01 20:39:24,255] INFO Waiting for keeper state SyncConnected (org.I0Itec.zkclient.ZkClient) [2017-11-01 20:39:24,255] INFO Opening socket connection to server 127.0.0.1/127.0.0.1:2181. Will not attempt to authenticate using SASL (unknown error) (org.apache.zookeeper.ClientCnxn) [2017-11-01 20:39:24,255] INFO Socket connection established to 127.0.0.1/127.0.0.1:2181, initiating session (org.apache.zookeeper.ClientCnxn) [2017-11-01 20:39:24,349] INFO Session establishment complete on server 127.0.0.1/127.0.0.1:2181, sessionid = 0x15f782112f60000, negotiated timeout = 6000 (org.apache.zookeeper.ClientCnxn) [2017-11-01 20:39:24,349] INFO zookeeper state changed (SyncConnected) (org.I0Itec.zkclient.ZkClient) [2017-11-01 20:39:24,489] INFO Cluster ID = liuqxXzOQHqLqf9AA5UKoA (kafka.server.KafkaServer) [2017-11-01 20:39:24,520] INFO [ThrottledRequestReaper-Fetch]: Starting (kafka.server.ClientQuotaManager$ThrottledRequestReaper) [2017-11-01 20:39:24,520] INFO [ThrottledRequestReaper-Produce]: Starting (kafka.server.ClientQuotaManager$ThrottledRequestReaper) [2017-11-01 20:39:24,520] INFO [ThrottledRequestReaper-Request]: Starting (kafka.server.ClientQuotaManager$ThrottledRequestReaper) [2017-11-01 20:39:24,567] INFO Loading logs. (kafka.log.LogManager) [2017-11-01 20:39:24,583] INFO Logs loading complete in 16 ms. (kafka.log.LogManager) [2017-11-01 20:39:24,630] WARN Error processing kafka.log:type=LogManager,name=LogDirectoryOffline,logDirectory=D:\tmp\kafka-logs (com.yammer.metrics.reporting.JmxReporter) javax.management.MalformedObjectNameException: Invalid character ':' in value part of property at javax.management.ObjectName.construct(ObjectName.java:618) at javax.management.ObjectName.(ObjectName.java:1382) at com.yammer.metrics.reporting.JmxReporter.onMetricAdded(JmxReporter.java:395) at com.yammer.metrics.core.MetricsRegistry.notifyMetricAdded(MetricsRegistry.java:516) at com.yammer.metrics.core.MetricsRegistry.getOrAdd(MetricsRegistry.java:491) at com.yammer.metrics.core.MetricsRegistry.newGauge(MetricsRegistry.java:79) at kafka.metrics.KafkaMetricsGroup.newGauge(KafkaMetricsGroup.scala:74) at kafka.metrics.KafkaMetricsGroup.newGauge$(KafkaMetricsGroup.scala:73) at kafka.log.LogManager.newGauge(LogManager.scala:50) at kafka.log.LogManager.$anonfun$new$1(LogManager.scala:122) at scala.collection.mutable.ResizableArray.foreach(ResizableArray.scala:59) at scala.collection.mutable.ResizableArray.foreach$(ResizableArray.scala:52) at scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:48) at kafka.log.LogManager.(LogManager.scala:116) at kafka.log.LogManager$.apply(LogManager.scala:814) at kafka.server.KafkaServer.startup(KafkaServer.scala:222) at kafka.server.KafkaServerStartable.startup(KafkaServerStartable.scala:38) at kafka.Kafka$.main(Kafka.scala:92) at kafka.Kafka.main(Kafka.scala) [2017-11-01 20:39:24,630] INFO Starting log cleanup with a period of 300000 ms. (kafka.log.LogManager) [2017-11-01 20:39:24,630] INFO Starting log flusher with a default period of 9223372036854775807 ms. (kafka.log.LogManager) [2017-11-01 20:39:24,833] INFO Awaiting socket connections on 0.0.0.0:9092. (kafka.network.Acceptor) [2017-11-01 20:39:24,833] INFO [SocketServer brokerId=0] Started 1 acceptor threads (kafka.network.SocketServer) [2017-11-01 20:39:24,849] INFO [ExpirationReaper-0-Produce]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2017-11-01 20:39:24,849] INFO [ExpirationReaper-0-Fetch]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2017-11-01 20:39:24,864] INFO [ExpirationReaper-0-DeleteRecords]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2017-11-01 20:39:24,864] INFO [LogDirFailureHandler]: Starting (kafka.server.ReplicaManager$LogDirFailureHandler) [2017-11-01 20:39:24,895] INFO [ExpirationReaper-0-topic]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2017-11-01 20:39:24,895] INFO [ExpirationReaper-0-Heartbeat]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2017-11-01 20:39:24,895] INFO [ExpirationReaper-0-Rebalance]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2017-11-01 20:39:24,911] INFO Creating /controller (is it secure? false) (kafka.utils.ZKCheckedEphemeral) [2017-11-01 20:39:24,911] INFO [GroupCoordinator 0]: Starting up. (kafka.coordinator.group.GroupCoordinator) [2017-11-01 20:39:24,911] INFO [GroupCoordinator 0]: Startup complete. (kafka.coordinator.group.GroupCoordinator) [2017-11-01 20:39:24,911] INFO [GroupMetadataManager brokerId=0] Removed 0 expired offsets in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2017-11-01 20:39:24,927] INFO Result of znode creation is: OK (kafka.utils.ZKCheckedEphemeral) [2017-11-01 20:39:24,942] INFO [ProducerId Manager 0]: Acquired new producerId block (brokerId:0,blockStartProducerId:1000,blockEndProducerId:1999) by writing to Zk with path version 2 (kafka.coordinator.transaction.ProducerIdManager) [2017-11-01 20:39:24,974] INFO [TransactionCoordinator id=0] Starting up. (kafka.coordinator.transaction.TransactionCoordinator) [2017-11-01 20:39:24,974] INFO [Transaction Marker Channel Manager 0]: Starting (kafka.coordinator.transaction.TransactionMarkerChannelManager) [2017-11-01 20:39:24,974] INFO [TransactionCoordinator id=0] Startup complete. (kafka.coordinator.transaction.TransactionCoordinator) [2017-11-01 20:39:25,005] INFO Creating /brokers/ids/0 (is it secure? false) (kafka.utils.ZKCheckedEphemeral) [2017-11-01 20:39:25,052] INFO Result of znode creation is: OK (kafka.utils.ZKCheckedEphemeral) [2017-11-01 20:39:25,052] INFO Registered broker 0 at path /brokers/ids/0 with addresses: EndPoint(Kedar-HP,9092,ListenerName(PLAINTEXT),PLAINTEXT) (kafka.utils.ZkUtils) [2017-11-01 20:39:25,052] INFO Kafka version : 1.0.0 (org.apache.kafka.common.utils.AppInfoParser) [2017-11-01 20:39:25,052] INFO Kafka commitId : aaa7af6d4a11b29d (org.apache.kafka.common.utils.AppInfoParser) [2017-11-01 20:39:25,052] INFO [KafkaServer id=0] started (kafka.server.KafkaServer)