Kafka web console error
Hi, Using kafka-Web-Console: when i run the command play start, it works fine. I tried to register the zookeeper, but getting the below error. *java.nio.channels.ClosedChannelException* at org.jboss.netty.channel.socket.nio.AbstractNioWorker.cleanUpWriteBuffer(AbstractNioWorker.java:433) at org.jboss.netty.channel.socket.nio.AbstractNioWorker.writeFromUserCode(AbstractNioWorker.java:128) at org.jboss.netty.channel.socket.nio.NioServerSocketPipelineSink.handleAcceptedSocket(NioServerSocketPipelineSink.java:99) at org.jboss.netty.channel.socket.nio.NioServerSocketPipelineSink.eventSunk(NioServerSocketPipelineSink.java:36) at org.jboss.netty.channel.Channels.write(Channels.java:725) at org.jboss.netty.handler.codec.oneone.OneToOneEncoder.doEncode(OneToOneEncoder.java:71) at org.jboss.netty.handler.codec.oneone.OneToOneEncoder.handleDownstream(OneToOneEncoder.java:59) at com.typesafe.netty.http.pipelining.HttpPipeliningHandler.handleDownstream(HttpPipeliningHandler.java:106) at org.jboss.netty.channel.Channels.write(Channels.java:704) at org.jboss.netty.channel.Channels.write(Channels.java:671) at org.jboss.netty.channel.AbstractChannel.write(AbstractChannel.java:248) at play.core.server.netty.PlayDefaultUpstreamHandler$$anonfun$play$core$server$netty$PlayDefaultUpstreamHandler$$iteratee$1$1.apply(PlayDefaultUpstreamHandler.scala:295) at play.core.server.netty.PlayDefaultUpstreamHandler$$anonfun$play$core$server$netty$PlayDefaultUpstreamHandler$$iteratee$1$1.apply(PlayDefaultUpstreamHandler.scala:292) at play.api.libs.iteratee.Iteratee$$anonfun$flatMap$1$$anonfun$apply$16.apply(Iteratee.scala:501) at play.api.libs.iteratee.Iteratee$$anonfun$flatMap$1$$anonfun$apply$16.apply(Iteratee.scala:501) at play.api.libs.iteratee.Concurrent$$anonfun$1$$anonfun$apply$8.apply(Concurrent.scala:104) at play.api.libs.iteratee.Concurrent$$anonfun$1$$anonfun$apply$8.apply(Concurrent.scala:101) at play.api.libs.iteratee.ImmediateIteratee$$anonfun$fold$2.apply(Iteratee.scala:595) at play.api.libs.iteratee.ImmediateIteratee$$anonfun$fold$2.apply(Iteratee.scala:595) at scala.concurrent.impl.Future$PromiseCompletingRunnable.liftedTree1$1(Future.scala:24) at scala.concurrent.impl.Future$PromiseCompletingRunnable.run(Future.scala:24) at play.api.libs.iteratee.Execution$$anon$1.execute(Execution.scala:43) at scala.concurrent.impl.Future$.apply(Future.scala:31) at scala.concurrent.Future$.apply(Future.scala:482) at play.api.libs.iteratee.internal$.executeFuture(package.scala:35) at play.api.libs.iteratee.ImmediateIteratee$class.fold(Iteratee.scala:596) at play.api.libs.iteratee.ContIteratee.fold(Iteratee.scala:640) at play.api.libs.iteratee.FutureIteratee$$anonfun$fold$3.apply(Iteratee.scala:659) at play.api.libs.iteratee.FutureIteratee$$anonfun$fold$3.apply(Iteratee.scala:659) at scala.concurrent.Future$$anonfun$flatMap$1.apply(Future.scala:251) at scala.concurrent.Future$$anonfun$flatMap$1.apply(Future.scala:249) at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:32) at play.api.libs.iteratee.Execution$$anon$2.execute(Execution.scala:70) at scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:40) at scala.concurrent.impl.Promise$DefaultPromise.scala$concurrent$impl$Promise$DefaultPromise$$dispatchOrAddCallback(Promise.scala:280) at scala.concurrent.impl.Promise$DefaultPromise.onComplete(Promise.scala:270) at scala.concurrent.Future$class.flatMap(Future.scala:249) at scala.concurrent.impl.Promise$DefaultPromise.flatMap(Promise.scala:153) at play.api.libs.iteratee.FutureIteratee.fold(Iteratee.scala:659) at play.api.libs.iteratee.FutureIteratee$$anonfun$fold$3.apply(Iteratee.scala:659) at play.api.libs.iteratee.FutureIteratee$$anonfun$fold$3.apply(Iteratee.scala:659) at scala.concurrent.Future$$anonfun$flatMap$1.apply(Future.scala:251) at scala.concurrent.Future$$anonfun$flatMap$1.apply(Future.scala:249) at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:32) at play.api.libs.iteratee.Execution$$anon$2.execute(Execution.scala:70) at scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:40) at scala.concurrent.impl.Promise$DefaultPromise.scala$concurrent$impl$Promise$DefaultPromise$$dispatchOrAddCallback(Promise.scala:280) at scala.concurrent.impl.Promise$DefaultPromise.onComplete(Promise.scala:270) at scala.concurrent.Future$class.flatMap(Future.scala:249) at scala.concurrent.impl.Promise$DefaultPromise.flatMap(Promise.scala:153) at play.api.libs.iteratee.FutureIteratee.fold(Iteratee.scala:659) at play.api.libs.iteratee.Iteratee$class.pureFold(Iteratee.scala:416) at
Re: kafka-web-console goes down regularly
I saw performance issues with the web console whenever using a large number of partitions (1000 partitions). On 2/3/15 12:09 PM, Sa Li wrote: Hi, All I am currently using kafka-web-console to monitor the kafka system, it get down regularly, so I have to restart it every few hours which is kinda annoying. I downloaded two versions https://github.com/claudemamo/kafka-web-console http://mungeol-heo.blogspot.ca/2014/12/kafka-web-console.html And I started by play start (using 9000), or play "start -Dhttp.port=8080", either version can make it work fine at the beginning, but down after few hours. I am thinking use upstart to make it up automatically, but it should not be what is suppose to be, any idea to fix the problem, or I did something wrong? thanks
Re: kafka-web-console goes down regularly
Good idea, Joel, will do it now. Thanks AL On Tue, Feb 3, 2015 at 2:12 PM, Joel Koshy wrote: > Can you contact the maintainer directly? > http://github.com/claudemamo/kafka-web-console/issues > > On Tue, Feb 03, 2015 at 12:09:46PM -0800, Sa Li wrote: > > Hi, All > > > > I am currently using kafka-web-console to monitor the kafka system, it > get > > down regularly, so I have to restart it every few hours which is kinda > > annoying. I downloaded two versions > > > > https://github.com/claudemamo/kafka-web-console > > http://mungeol-heo.blogspot.ca/2014/12/kafka-web-console.html > > > > And I started by > > > > play start (using 9000), or play "start -Dhttp.port=8080", either version > > can make it work fine at the beginning, but down after few hours. I am > > thinking use upstart to make it up automatically, but it should not be > what > > is suppose to be, any idea to fix the problem, or I did something wrong? > > > > thanks > > > > -- > > > > Alec Li > > -- Alec Li
Re: kafka-web-console goes down regularly
Can you contact the maintainer directly? http://github.com/claudemamo/kafka-web-console/issues On Tue, Feb 03, 2015 at 12:09:46PM -0800, Sa Li wrote: > Hi, All > > I am currently using kafka-web-console to monitor the kafka system, it get > down regularly, so I have to restart it every few hours which is kinda > annoying. I downloaded two versions > > https://github.com/claudemamo/kafka-web-console > http://mungeol-heo.blogspot.ca/2014/12/kafka-web-console.html > > And I started by > > play start (using 9000), or play "start -Dhttp.port=8080", either version > can make it work fine at the beginning, but down after few hours. I am > thinking use upstart to make it up automatically, but it should not be what > is suppose to be, any idea to fix the problem, or I did something wrong? > > thanks > > -- > > Alec Li
kafka-web-console goes down regularly
Hi, All I am currently using kafka-web-console to monitor the kafka system, it get down regularly, so I have to restart it every few hours which is kinda annoying. I downloaded two versions https://github.com/claudemamo/kafka-web-console http://mungeol-heo.blogspot.ca/2014/12/kafka-web-console.html And I started by play start (using 9000), or play "start -Dhttp.port=8080", either version can make it work fine at the beginning, but down after few hours. I am thinking use upstart to make it up automatically, but it should not be what is suppose to be, any idea to fix the problem, or I did something wrong? thanks -- Alec Li
Re: kafka-web-console error
Continue this kafka-web-console thread, I follow such page: http://mungeol-heo.blogspot.ca/2014/12/kafka-web-console.html I run the command: play "start -Dhttp.port=8080" It works good for a while, but getting such error : at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) Caused by: java.sql.SQLException: Timed out waiting for a free available connection. at com.jolbox.bonecp.DefaultConnectionStrategy.getConnectionInternal(DefaultConnectionStrategy.java:88) at com.jolbox.bonecp.AbstractConnectionStrategy.getConnection(AbstractConnectionStrategy.java:90) at com.jolbox.bonecp.BoneCP.getConnection(BoneCP.java:553) at com.jolbox.bonecp.BoneCPDataSource.getConnection(BoneCPDataSource.java:131) at play.api.db.DBApi$class.getConnection(DB.scala:67) at play.api.db.BoneCPApi.getConnection(DB.scala:276) at play.api.db.DB$$anonfun$getConnection$1.apply(DB.scala:133) at play.api.db.DB$$anonfun$getConnection$1.apply(DB.scala:133) at scala.Option.map(Option.scala:145) at play.api.db.DB$.getConnection(DB.scala:133) at Global$.Global$$getSession(Global.scala:58) at Global$$anonfun$initiateDb$1.apply(Global.scala:47) at Global$$anonfun$initiateDb$1.apply(Global.scala:47) at org.squeryl.SessionFactory$.newSession(Session.scala:95) at org.squeryl.dsl.QueryDsl$class.inTransaction(QueryDsl.scala:100) at org.squeryl.PrimitiveTypeMode$.inTransaction(PrimitiveTypeMode.scala:40) at models.Setting$.findByKey(Setting.scala:46) at actors.OffsetHistoryManager.actors$OffsetHistoryManager$$schedule(OffsetHistoryManager.scala:102) at actors.OffsetHistoryManager.preStart(OffsetHistoryManager.scala:55) at akka.actor.Actor$class.postRestart(Actor.scala:532) at actors.OffsetHistoryManager.postRestart(OffsetHistoryManager.scala:41) at akka.actor.dungeon.FaultHandling$class.finishRecreate(FaultHandling.scala:229) ... 11 more Any hints? thanks AL On Fri, Jan 2, 2015 at 5:07 PM, Joe Stein wrote: > The kafka project doesn't have an official web console so you might need to > open an issue on the github page of the project for the web console you are > using as they may not be closing connections and using up all of resources > regardless of what you have set, etc if you have the default setting > you may have to increase this value for the operating system if it is not a > bug in the client you are using. You can give > http://www.cyberciti.biz/faq/howto-linux-get-list-of-open-files/ a try to > ascertain which is the problem and/or do a ulimit -n on your machine and > see if the value = 1024 which is the default likely for your OS. > > /*** > Joe Stein > Founder, Principal Consultant > Big Data Open Source Security LLC > http://www.stealth.ly > Twitter: @allthingshadoop <http://www.twitter.com/allthingshadoop> > / > > On Fri, Jan 2, 2015 at 7:41 PM, Sa Li wrote: > > > Hi, all > > > > I am running kafka-web-console, I periodically getting such error and > cause > > the UI down: > > > > > > > > ! @6kldaf9lj - Internal server error, for (GET) > > [/assets/images/zookeeper_small.gif] -> > > play.api.Application$$anon$1: Execution exception[[FileNotFoundException: > > > > > /vagrant/kafka-web-console-master/target/scala-2.10/classes/public/images/zookeeper_small.gif > > (Too many open files)]] > > at play.api.Application$class.handleError(Application.scala:293) > > ~[play_2.10-2.2.1.jar:2.2.1] > > at play.api.DefaultApplication.handleError(Application.scala:399) > > [play_2.10-2.2.1.jar:2.2.1] > > at > > > > > play.core.server.netty.PlayDefaultUpstreamHandler$$anonfun$12$$anonfun$apply$1.applyOrElse(PlayDefaultUpstreamHandler.scala:165) > > [play_2.10-2.2.1.jar:2.2.1] > > at > > > > > play.core.server.netty.PlayDefaultUpstreamHandler$$anonfun$12$$anonfun$apply$1.applyOrElse(PlayDefaultUpstreamHandler.scala:162) > > [play_2.10-2.2.1.jar:2.2.1] > > at > > > > > scala.runtime.AbstractPartialFunction.apply(AbstractPartialFunction.scala:33) > > [scala-library-2.10.2.jar:na] > > at scala.util.Failure$$anonfun$recover$1.apply(Try.scala:185) > > [scala-library-2.10.2.jar:na] > > Caused by: java.io.FileNotFoundException: > > &g
Re: kafka-web-console error
The kafka project doesn't have an official web console so you might need to open an issue on the github page of the project for the web console you are using as they may not be closing connections and using up all of resources regardless of what you have set, etc if you have the default setting you may have to increase this value for the operating system if it is not a bug in the client you are using. You can give http://www.cyberciti.biz/faq/howto-linux-get-list-of-open-files/ a try to ascertain which is the problem and/or do a ulimit -n on your machine and see if the value = 1024 which is the default likely for your OS. /*** Joe Stein Founder, Principal Consultant Big Data Open Source Security LLC http://www.stealth.ly Twitter: @allthingshadoop <http://www.twitter.com/allthingshadoop> / On Fri, Jan 2, 2015 at 7:41 PM, Sa Li wrote: > Hi, all > > I am running kafka-web-console, I periodically getting such error and cause > the UI down: > > > > ! @6kldaf9lj - Internal server error, for (GET) > [/assets/images/zookeeper_small.gif] -> > play.api.Application$$anon$1: Execution exception[[FileNotFoundException: > > /vagrant/kafka-web-console-master/target/scala-2.10/classes/public/images/zookeeper_small.gif > (Too many open files)]] > at play.api.Application$class.handleError(Application.scala:293) > ~[play_2.10-2.2.1.jar:2.2.1] > at play.api.DefaultApplication.handleError(Application.scala:399) > [play_2.10-2.2.1.jar:2.2.1] > at > > play.core.server.netty.PlayDefaultUpstreamHandler$$anonfun$12$$anonfun$apply$1.applyOrElse(PlayDefaultUpstreamHandler.scala:165) > [play_2.10-2.2.1.jar:2.2.1] > at > > play.core.server.netty.PlayDefaultUpstreamHandler$$anonfun$12$$anonfun$apply$1.applyOrElse(PlayDefaultUpstreamHandler.scala:162) > [play_2.10-2.2.1.jar:2.2.1] > at > > scala.runtime.AbstractPartialFunction.apply(AbstractPartialFunction.scala:33) > [scala-library-2.10.2.jar:na] > at scala.util.Failure$$anonfun$recover$1.apply(Try.scala:185) > [scala-library-2.10.2.jar:na] > Caused by: java.io.FileNotFoundException: > > /vagrant/kafka-web-console-master/target/scala-2.10/classes/public/images/zookeeper_small.gif > (Too many open files) > at java.io.FileInputStream.open(Native Method) ~[na:1.7.0_65] > at java.io.FileInputStream.(FileInputStream.java:146) > ~[na:1.7.0_65] > at java.io.FileInputStream.(FileInputStream.java:101) > ~[na:1.7.0_65] > at > > sun.net.www.protocol.file.FileURLConnection.connect(FileURLConnection.java:90) > ~[na:1.7.0_65] > at > > sun.net.www.protocol.file.FileURLConnection.getInputStream(FileURLConnection.java:188) > ~[na:1.7.0_65] > at java.net.URL.openStream(URL.java:1037) ~[na:1.7.0_65] > > [debug] application - Getting partition offsets for topic ui_test_topic_6 > [warn] application - Could not connect to partition leader > exemplary-birds.master:9092. Error message: Failed to open a socket. > [debug] application - Getting partition offsets for topic ui_test_topic_5 > [warn] application - Could not connect to partition leader > exemplary-birds.master:9092. Error message: Failed to open a socket. > [warn] application - Could not connect to partition leader > harmful-jar.master:9092. Error message: Failed to open a socket. > [warn] application - Could not connect to partition leader > voluminous-mass.master:9092. Error message: Failed to open a socket. > [warn] application - Could not connect to partition leader > voluminous-mass.master:9092. Error message: Failed to open a socket. > [warn] application - Could not connect to partition leader > exemplary-birds.master:9092. Error message: Failed to open a socket. > [warn] application - Could not connect to partition leader > exemplary-birds.master:9092. Error message: Failed to open a socket. > [warn] application - Could not connect to partition leader > harmful-jar.master:9092. Error message: Failed to open a socket. > [warn] application - Could not connect to partition leader > harmful-jar.master:9092. Error message: Failed to open a socket. > [warn] application - Could not connect to partition leader > voluminous-mass.master:9092. Error message: Failed to open a socket. > [warn] application - Could not connect to partition leader > voluminous-mass.master:9092. Error message: Failed to open a socket. > [warn] application - Could not connect to partition leader > exemplary-birds.master:9092. Error message: Failed to open a socket. > [warn] application - Could not connect to partition leader > harmful-jar.master:9092. Error message: Failed to open a socket. > [warn] application - Could not connect to p
kafka-web-console error
Hi, all I am running kafka-web-console, I periodically getting such error and cause the UI down: ! @6kldaf9lj - Internal server error, for (GET) [/assets/images/zookeeper_small.gif] -> play.api.Application$$anon$1: Execution exception[[FileNotFoundException: /vagrant/kafka-web-console-master/target/scala-2.10/classes/public/images/zookeeper_small.gif (Too many open files)]] at play.api.Application$class.handleError(Application.scala:293) ~[play_2.10-2.2.1.jar:2.2.1] at play.api.DefaultApplication.handleError(Application.scala:399) [play_2.10-2.2.1.jar:2.2.1] at play.core.server.netty.PlayDefaultUpstreamHandler$$anonfun$12$$anonfun$apply$1.applyOrElse(PlayDefaultUpstreamHandler.scala:165) [play_2.10-2.2.1.jar:2.2.1] at play.core.server.netty.PlayDefaultUpstreamHandler$$anonfun$12$$anonfun$apply$1.applyOrElse(PlayDefaultUpstreamHandler.scala:162) [play_2.10-2.2.1.jar:2.2.1] at scala.runtime.AbstractPartialFunction.apply(AbstractPartialFunction.scala:33) [scala-library-2.10.2.jar:na] at scala.util.Failure$$anonfun$recover$1.apply(Try.scala:185) [scala-library-2.10.2.jar:na] Caused by: java.io.FileNotFoundException: /vagrant/kafka-web-console-master/target/scala-2.10/classes/public/images/zookeeper_small.gif (Too many open files) at java.io.FileInputStream.open(Native Method) ~[na:1.7.0_65] at java.io.FileInputStream.(FileInputStream.java:146) ~[na:1.7.0_65] at java.io.FileInputStream.(FileInputStream.java:101) ~[na:1.7.0_65] at sun.net.www.protocol.file.FileURLConnection.connect(FileURLConnection.java:90) ~[na:1.7.0_65] at sun.net.www.protocol.file.FileURLConnection.getInputStream(FileURLConnection.java:188) ~[na:1.7.0_65] at java.net.URL.openStream(URL.java:1037) ~[na:1.7.0_65] [debug] application - Getting partition offsets for topic ui_test_topic_6 [warn] application - Could not connect to partition leader exemplary-birds.master:9092. Error message: Failed to open a socket. [debug] application - Getting partition offsets for topic ui_test_topic_5 [warn] application - Could not connect to partition leader exemplary-birds.master:9092. Error message: Failed to open a socket. [warn] application - Could not connect to partition leader harmful-jar.master:9092. Error message: Failed to open a socket. [warn] application - Could not connect to partition leader voluminous-mass.master:9092. Error message: Failed to open a socket. [warn] application - Could not connect to partition leader voluminous-mass.master:9092. Error message: Failed to open a socket. [warn] application - Could not connect to partition leader exemplary-birds.master:9092. Error message: Failed to open a socket. [warn] application - Could not connect to partition leader exemplary-birds.master:9092. Error message: Failed to open a socket. [warn] application - Could not connect to partition leader harmful-jar.master:9092. Error message: Failed to open a socket. [warn] application - Could not connect to partition leader harmful-jar.master:9092. Error message: Failed to open a socket. [warn] application - Could not connect to partition leader voluminous-mass.master:9092. Error message: Failed to open a socket. [warn] application - Could not connect to partition leader voluminous-mass.master:9092. Error message: Failed to open a socket. [warn] application - Could not connect to partition leader exemplary-birds.master:9092. Error message: Failed to open a socket. [warn] application - Could not connect to partition leader harmful-jar.master:9092. Error message: Failed to open a socket. [warn] application - Could not connect to partition leader exemplary-birds.master:9092. Error message: Failed to open a socket. [debug] application - Getting partition offsets for topic PofApiTest [warn] application - Could not connect to partition leader harmful-jar.master:9092. Error message: Failed to open a socket. [warn] application - Could not connect to partition leader voluminous-mass.master:9092. Error message: Failed to open a socket. [warn] application - Could not connect to partition leader exemplary-birds.master:9092. Error message: Failed to open a socket. [debug] application - Getting partition offsets for topic ui_test_topic_4 What that means too many files open, is that mean the insufficient local memory? thanks -- Alec Li
Re: kafka web console running error
You will need to contact the owner of that project directly. Thanks, Jun On Thu, Nov 27, 2014 at 11:40 AM, Sa Li wrote: > I am using https://github.com/claudemamo/kafka-web-console version, and do > you mind to tell where about to make such modification? > > thanks > > Alec > > On Mon, Nov 24, 2014 at 11:16 PM, Yang Fang > wrote: > > > do you see error msg "Too many open files"? it tips you should modify > > nofile > > > > On Tue, Nov 25, 2014 at 1:26 PM, Jun Rao wrote: > > > > > Which web console are you using? > > > > > > Thanks, > > > > > > Jun > > > > > > On Fri, Nov 21, 2014 at 8:34 AM, Sa Li wrote: > > > > > > > Hi, all > > > > > > > > I am trying to get kafka web console work, but seems it only works > few > > > > hours and fails afterwards, below is the error messages on the > screen. > > I > > > am > > > > assuming something wrong with the DB, I used to swap H2 to mysql, but > > > > didn't help. Anyone has similar problem? > > > > > > > > > > > > - > > > > . > > > > . > > > > > > > > > > > >at sun.misc.Resource.getByteBuffer(Resource.java:160) > ~[na:1.7.0_65] > > > > at > java.net.URLClassLoader.defineClass(URLClassLoader.java:436) > > > > ~[na:1.7.0_65] > > > > > > > > at > > > > > > > > > > > > > > akka.dispatch.BatchingExecutor$Batch$$anonfun$run$1.processBatch$1(BatchingExecutor.scala:67) > > > > at > > > > > > > > > > > > > > akka.dispatch.BatchingExecutor$Batch$$anonfun$run$1.apply$mcV$sp(BatchingExecutor.scala:82) > > > > at > > > > > > > > > > > > > > akka.dispatch.BatchingExecutor$Batch$$anonfun$run$1.apply(BatchingExecutor.scala:59) > > > > at > > > > > > > > > > > > > > akka.dispatch.BatchingExecutor$Batch$$anonfun$run$1.apply(BatchingExecutor.scala:59) > > > > at > > > > > scala.concurrent.BlockContext$.withBlockContext(BlockContext.scala:72) > > > > at > > > > akka.dispatch.BatchingExecutor$Batch.run(BatchingExecutor.scala:58) > > > > at > > akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:42) > > > > at > > > > > > > > > > > > > > akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:386) > > > > at > > > > scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) > > > > at > > > > > > > > > > > > > > scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) > > > > at > > > > > > scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) > > > > at > > > > > > > > > > > > > > scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) > > > > [ERROR] Failed to construct terminal; falling back to unsupported > > > > java.io.IOException: Cannot run program "sh": error=24, Too many open > > > files > > > > at java.lang.ProcessBuilder.start(ProcessBuilder.java:1047) > > > > at java.lang.Runtime.exec(Runtime.java:617) > > > > at java.lang.Runtime.exec(Runtime.java:485) > > > > at > > > > > jline.internal.TerminalLineSettings.exec(TerminalLineSettings.java:183) > > > > at > > > > > jline.internal.TerminalLineSettings.exec(TerminalLineSettings.java:173) > > > > at > > > > > jline.internal.TerminalLineSettings.stty(TerminalLineSettings.java:168) > > > > at > > > > jline.internal.TerminalLineSettings.get(TerminalLineSettings.java:72) > > > > at > > > > > > jline.internal.TerminalLineSettings.(TerminalLineSettings.java:52) > > > > at jline.UnixTerminal.(UnixTerminal.java:31) > > > > at > > sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native > > > > Method) > > > > at > > > > > > > > > > > > > > sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImp
Re: kafka web console running error
I am using https://github.com/claudemamo/kafka-web-console version, and do you mind to tell where about to make such modification? thanks Alec On Mon, Nov 24, 2014 at 11:16 PM, Yang Fang wrote: > do you see error msg "Too many open files"? it tips you should modify > nofile > > On Tue, Nov 25, 2014 at 1:26 PM, Jun Rao wrote: > > > Which web console are you using? > > > > Thanks, > > > > Jun > > > > On Fri, Nov 21, 2014 at 8:34 AM, Sa Li wrote: > > > > > Hi, all > > > > > > I am trying to get kafka web console work, but seems it only works few > > > hours and fails afterwards, below is the error messages on the screen. > I > > am > > > assuming something wrong with the DB, I used to swap H2 to mysql, but > > > didn't help. Anyone has similar problem? > > > > > > > > > - > > > . > > > . > > > > > > > > >at sun.misc.Resource.getByteBuffer(Resource.java:160) ~[na:1.7.0_65] > > > at java.net.URLClassLoader.defineClass(URLClassLoader.java:436) > > > ~[na:1.7.0_65] > > > > > > at > > > > > > > > > akka.dispatch.BatchingExecutor$Batch$$anonfun$run$1.processBatch$1(BatchingExecutor.scala:67) > > > at > > > > > > > > > akka.dispatch.BatchingExecutor$Batch$$anonfun$run$1.apply$mcV$sp(BatchingExecutor.scala:82) > > > at > > > > > > > > > akka.dispatch.BatchingExecutor$Batch$$anonfun$run$1.apply(BatchingExecutor.scala:59) > > > at > > > > > > > > > akka.dispatch.BatchingExecutor$Batch$$anonfun$run$1.apply(BatchingExecutor.scala:59) > > > at > > > scala.concurrent.BlockContext$.withBlockContext(BlockContext.scala:72) > > > at > > > akka.dispatch.BatchingExecutor$Batch.run(BatchingExecutor.scala:58) > > > at > akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:42) > > > at > > > > > > > > > akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:386) > > > at > > > scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) > > > at > > > > > > > > > scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) > > > at > > > > scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) > > > at > > > > > > > > > scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) > > > [ERROR] Failed to construct terminal; falling back to unsupported > > > java.io.IOException: Cannot run program "sh": error=24, Too many open > > files > > > at java.lang.ProcessBuilder.start(ProcessBuilder.java:1047) > > > at java.lang.Runtime.exec(Runtime.java:617) > > > at java.lang.Runtime.exec(Runtime.java:485) > > > at > > > jline.internal.TerminalLineSettings.exec(TerminalLineSettings.java:183) > > > at > > > jline.internal.TerminalLineSettings.exec(TerminalLineSettings.java:173) > > > at > > > jline.internal.TerminalLineSettings.stty(TerminalLineSettings.java:168) > > > at > > > jline.internal.TerminalLineSettings.get(TerminalLineSettings.java:72) > > > at > > > > jline.internal.TerminalLineSettings.(TerminalLineSettings.java:52) > > > at jline.UnixTerminal.(UnixTerminal.java:31) > > > at > sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native > > > Method) > > > at > > > > > > > > > sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:57) > > > at > > > > > > > > > sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) > > > at > > java.lang.reflect.Constructor.newInstance(Constructor.java:526) > > > at java.lang.Class.newInstance(Class.java:379) > > > [error] a.a.ActorSystemImpl - Uncaught error from thread > > > [play-akka.actor.default-dispatcher-944] shutting down JVM since > > > 'akka.jvm-exit-on-fatal-error' > > > java.lang.NoClassDefFoundError: > > > > > > > > > common/Util$$anonfun$getPartitionsLogSize$3$$anonfun$apply$19$$anonfun$apply$1$$anonfun$applyOrElse$1 > > >
Re: kafka web console running error
do you see error msg "Too many open files"? it tips you should modify nofile On Tue, Nov 25, 2014 at 1:26 PM, Jun Rao wrote: > Which web console are you using? > > Thanks, > > Jun > > On Fri, Nov 21, 2014 at 8:34 AM, Sa Li wrote: > > > Hi, all > > > > I am trying to get kafka web console work, but seems it only works few > > hours and fails afterwards, below is the error messages on the screen. I > am > > assuming something wrong with the DB, I used to swap H2 to mysql, but > > didn't help. Anyone has similar problem? > > > > > > - > > . > > . > > > > > >at sun.misc.Resource.getByteBuffer(Resource.java:160) ~[na:1.7.0_65] > > at java.net.URLClassLoader.defineClass(URLClassLoader.java:436) > > ~[na:1.7.0_65] > > > > at > > > > > akka.dispatch.BatchingExecutor$Batch$$anonfun$run$1.processBatch$1(BatchingExecutor.scala:67) > > at > > > > > akka.dispatch.BatchingExecutor$Batch$$anonfun$run$1.apply$mcV$sp(BatchingExecutor.scala:82) > > at > > > > > akka.dispatch.BatchingExecutor$Batch$$anonfun$run$1.apply(BatchingExecutor.scala:59) > > at > > > > > akka.dispatch.BatchingExecutor$Batch$$anonfun$run$1.apply(BatchingExecutor.scala:59) > > at > > scala.concurrent.BlockContext$.withBlockContext(BlockContext.scala:72) > > at > > akka.dispatch.BatchingExecutor$Batch.run(BatchingExecutor.scala:58) > > at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:42) > > at > > > > > akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:386) > > at > > scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) > > at > > > > > scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) > > at > > scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) > > at > > > > > scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) > > [ERROR] Failed to construct terminal; falling back to unsupported > > java.io.IOException: Cannot run program "sh": error=24, Too many open > files > > at java.lang.ProcessBuilder.start(ProcessBuilder.java:1047) > > at java.lang.Runtime.exec(Runtime.java:617) > > at java.lang.Runtime.exec(Runtime.java:485) > > at > > jline.internal.TerminalLineSettings.exec(TerminalLineSettings.java:183) > > at > > jline.internal.TerminalLineSettings.exec(TerminalLineSettings.java:173) > > at > > jline.internal.TerminalLineSettings.stty(TerminalLineSettings.java:168) > > at > > jline.internal.TerminalLineSettings.get(TerminalLineSettings.java:72) > > at > > jline.internal.TerminalLineSettings.(TerminalLineSettings.java:52) > > at jline.UnixTerminal.(UnixTerminal.java:31) > > at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native > > Method) > > at > > > > > sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:57) > > at > > > > > sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) > > at > java.lang.reflect.Constructor.newInstance(Constructor.java:526) > > at java.lang.Class.newInstance(Class.java:379) > > [error] a.a.ActorSystemImpl - Uncaught error from thread > > [play-akka.actor.default-dispatcher-944] shutting down JVM since > > 'akka.jvm-exit-on-fatal-error' > > java.lang.NoClassDefFoundError: > > > > > common/Util$$anonfun$getPartitionsLogSize$3$$anonfun$apply$19$$anonfun$apply$1$$anonfun$applyOrElse$1 > > at > > > > > common.Util$$anonfun$getPartitionsLogSize$3$$anonfun$apply$19$$anonfun$apply$1.applyOrElse(Util.scala:75) > > ~[na:na] > > at > > > > > common.Util$$anonfun$getPartitionsLogSize$3$$anonfun$apply$19$$anonfun$apply$1.applyOrElse(Util.scala:74) > > ~[na:na] > > at > > > > > scala.runtime.AbstractPartialFunction$mcJL$sp.apply$mcJL$sp(AbstractPartialFunction.scala:33) > > ~[scala-library.jar:na] > > at > > > > > scala.runtime.AbstractPartialFunction$mcJL$sp.apply(AbstractPartialFunction.scala:33) > > ~[scala-library.jar:na] > > at > > > > > scala.runtime.AbstractPartialFunction$mcJL$sp.apply(AbstractPartialFunction.scala:25) >
Re: kafka web console running error
Which web console are you using? Thanks, Jun On Fri, Nov 21, 2014 at 8:34 AM, Sa Li wrote: > Hi, all > > I am trying to get kafka web console work, but seems it only works few > hours and fails afterwards, below is the error messages on the screen. I am > assuming something wrong with the DB, I used to swap H2 to mysql, but > didn't help. Anyone has similar problem? > > > - > . > . > > >at sun.misc.Resource.getByteBuffer(Resource.java:160) ~[na:1.7.0_65] > at java.net.URLClassLoader.defineClass(URLClassLoader.java:436) > ~[na:1.7.0_65] > > at > > akka.dispatch.BatchingExecutor$Batch$$anonfun$run$1.processBatch$1(BatchingExecutor.scala:67) > at > > akka.dispatch.BatchingExecutor$Batch$$anonfun$run$1.apply$mcV$sp(BatchingExecutor.scala:82) > at > > akka.dispatch.BatchingExecutor$Batch$$anonfun$run$1.apply(BatchingExecutor.scala:59) > at > > akka.dispatch.BatchingExecutor$Batch$$anonfun$run$1.apply(BatchingExecutor.scala:59) > at > scala.concurrent.BlockContext$.withBlockContext(BlockContext.scala:72) > at > akka.dispatch.BatchingExecutor$Batch.run(BatchingExecutor.scala:58) > at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:42) > at > > akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:386) > at > scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) > at > > scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) > at > scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) > at > > scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) > [ERROR] Failed to construct terminal; falling back to unsupported > java.io.IOException: Cannot run program "sh": error=24, Too many open files > at java.lang.ProcessBuilder.start(ProcessBuilder.java:1047) > at java.lang.Runtime.exec(Runtime.java:617) > at java.lang.Runtime.exec(Runtime.java:485) > at > jline.internal.TerminalLineSettings.exec(TerminalLineSettings.java:183) > at > jline.internal.TerminalLineSettings.exec(TerminalLineSettings.java:173) > at > jline.internal.TerminalLineSettings.stty(TerminalLineSettings.java:168) > at > jline.internal.TerminalLineSettings.get(TerminalLineSettings.java:72) > at > jline.internal.TerminalLineSettings.(TerminalLineSettings.java:52) > at jline.UnixTerminal.(UnixTerminal.java:31) > at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native > Method) > at > > sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:57) > at > > sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) > at java.lang.reflect.Constructor.newInstance(Constructor.java:526) > at java.lang.Class.newInstance(Class.java:379) > [error] a.a.ActorSystemImpl - Uncaught error from thread > [play-akka.actor.default-dispatcher-944] shutting down JVM since > 'akka.jvm-exit-on-fatal-error' > java.lang.NoClassDefFoundError: > > common/Util$$anonfun$getPartitionsLogSize$3$$anonfun$apply$19$$anonfun$apply$1$$anonfun$applyOrElse$1 > at > > common.Util$$anonfun$getPartitionsLogSize$3$$anonfun$apply$19$$anonfun$apply$1.applyOrElse(Util.scala:75) > ~[na:na] > at > > common.Util$$anonfun$getPartitionsLogSize$3$$anonfun$apply$19$$anonfun$apply$1.applyOrElse(Util.scala:74) > ~[na:na] > at > > scala.runtime.AbstractPartialFunction$mcJL$sp.apply$mcJL$sp(AbstractPartialFunction.scala:33) > ~[scala-library.jar:na] > at > > scala.runtime.AbstractPartialFunction$mcJL$sp.apply(AbstractPartialFunction.scala:33) > ~[scala-library.jar:na] > at > > scala.runtime.AbstractPartialFunction$mcJL$sp.apply(AbstractPartialFunction.scala:25) > ~[scala-library.jar:na] > at scala.util.Failure$$anonfun$recover$1.apply(Try.scala:185) > ~[scala-library.jar:na] > at jline.TerminalFactory.getFlavor(TerminalFactory.java:168) > at jline.TerminalFactory.create(TerminalFactory.java:81) > at jline.TerminalFactory.get(TerminalFactory.java:159) > at sbt.MainLoop$$anon$1.run(MainLoop.scala:19) > at java.lang.Thread.run(Thread.java:745) > Caused by: java.io.IOException: error=24, Too many open files > at java.lang.UNIXProcess.forkAndExec(Native Method) > at java.lang.UNIXProcess.(UNIXProcess.java:186) > at java.lang.ProcessImpl.start(ProcessImpl.java:130) > at java.lang.ProcessBuil
kafka web console running error
Hi, all I am trying to get kafka web console work, but seems it only works few hours and fails afterwards, below is the error messages on the screen. I am assuming something wrong with the DB, I used to swap H2 to mysql, but didn't help. Anyone has similar problem? - . . at sun.misc.Resource.getByteBuffer(Resource.java:160) ~[na:1.7.0_65] at java.net.URLClassLoader.defineClass(URLClassLoader.java:436) ~[na:1.7.0_65] at akka.dispatch.BatchingExecutor$Batch$$anonfun$run$1.processBatch$1(BatchingExecutor.scala:67) at akka.dispatch.BatchingExecutor$Batch$$anonfun$run$1.apply$mcV$sp(BatchingExecutor.scala:82) at akka.dispatch.BatchingExecutor$Batch$$anonfun$run$1.apply(BatchingExecutor.scala:59) at akka.dispatch.BatchingExecutor$Batch$$anonfun$run$1.apply(BatchingExecutor.scala:59) at scala.concurrent.BlockContext$.withBlockContext(BlockContext.scala:72) at akka.dispatch.BatchingExecutor$Batch.run(BatchingExecutor.scala:58) at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:42) at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:386) at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) [ERROR] Failed to construct terminal; falling back to unsupported java.io.IOException: Cannot run program "sh": error=24, Too many open files at java.lang.ProcessBuilder.start(ProcessBuilder.java:1047) at java.lang.Runtime.exec(Runtime.java:617) at java.lang.Runtime.exec(Runtime.java:485) at jline.internal.TerminalLineSettings.exec(TerminalLineSettings.java:183) at jline.internal.TerminalLineSettings.exec(TerminalLineSettings.java:173) at jline.internal.TerminalLineSettings.stty(TerminalLineSettings.java:168) at jline.internal.TerminalLineSettings.get(TerminalLineSettings.java:72) at jline.internal.TerminalLineSettings.(TerminalLineSettings.java:52) at jline.UnixTerminal.(UnixTerminal.java:31) at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method) at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:57) at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) at java.lang.reflect.Constructor.newInstance(Constructor.java:526) at java.lang.Class.newInstance(Class.java:379) [error] a.a.ActorSystemImpl - Uncaught error from thread [play-akka.actor.default-dispatcher-944] shutting down JVM since 'akka.jvm-exit-on-fatal-error' java.lang.NoClassDefFoundError: common/Util$$anonfun$getPartitionsLogSize$3$$anonfun$apply$19$$anonfun$apply$1$$anonfun$applyOrElse$1 at common.Util$$anonfun$getPartitionsLogSize$3$$anonfun$apply$19$$anonfun$apply$1.applyOrElse(Util.scala:75) ~[na:na] at common.Util$$anonfun$getPartitionsLogSize$3$$anonfun$apply$19$$anonfun$apply$1.applyOrElse(Util.scala:74) ~[na:na] at scala.runtime.AbstractPartialFunction$mcJL$sp.apply$mcJL$sp(AbstractPartialFunction.scala:33) ~[scala-library.jar:na] at scala.runtime.AbstractPartialFunction$mcJL$sp.apply(AbstractPartialFunction.scala:33) ~[scala-library.jar:na] at scala.runtime.AbstractPartialFunction$mcJL$sp.apply(AbstractPartialFunction.scala:25) ~[scala-library.jar:na] at scala.util.Failure$$anonfun$recover$1.apply(Try.scala:185) ~[scala-library.jar:na] at jline.TerminalFactory.getFlavor(TerminalFactory.java:168) at jline.TerminalFactory.create(TerminalFactory.java:81) at jline.TerminalFactory.get(TerminalFactory.java:159) at sbt.MainLoop$$anon$1.run(MainLoop.scala:19) at java.lang.Thread.run(Thread.java:745) Caused by: java.io.IOException: error=24, Too many open files at java.lang.UNIXProcess.forkAndExec(Native Method) at java.lang.UNIXProcess.(UNIXProcess.java:186) at java.lang.ProcessImpl.start(ProcessImpl.java:130) at java.lang.ProcessBuilder.start(ProcessBuilder.java:1028) ... 18 more [error] a.a.ActorSystemImpl - Uncaught error from thread [play-akka.actor.default-dispatcher-943] shutting down JVM since 'akka.jvm-exit-on-fatal-error' java.lang.NoClassDefFoundError: common/Util$$anonfun$getPartitionsLogSize$3$$anonfun$apply$19$$anonfun$apply$1$$anonfun$applyOrElse$1 at common.Util$$anonfun$getPartitionsLogSize$3$$anonfun$apply$19$$anonfun$apply$1.applyOrElse(Util.scala:75) ~[na:na] at common.Util$$anonfun$getPartitionsLogSize$3$$anonfun$apply$19$$anonfun$apply$1.applyOrElse(Util.scala:74) ~[na:na] at scala.runtime.AbstractPa
Re: kafka-web-console
rm -f /root/.ivy2/.sbt.ivy.lock On Mon, Oct 13, 2014 at 8:39 PM, Sa Li wrote: > All, > > Again, I am still unable to install, seems to stuck on ivy.lock, any ideas > to continue? > > thanks > > Alec > > On Oct 12, 2014, at 7:38 PM, Sa Li wrote: > > > Hi > >
Re: kafka-web-console
All, Again, I am still unable to install, seems to stuck on ivy.lock, any ideas to continue? thanks Alec On Oct 12, 2014, at 7:38 PM, Sa Li wrote: > Hi
Re: kafka-web-console
Hi, Palak really? I terminated it since I truly thought it was stuck there, I will run it again. thanks Alec On Oct 12, 2014, at 7:35 PM, Palak Shah wrote: > Hi, > > I am sure you must have got it running by now, but in case you gave up > earlier, just have patience and it will start. > > Even I had faced this issue. The console takes a lot of time to start, but > eventually it does. So this is not an error :) > > Hope this helped, > -Palak > > On Sat, Oct 11, 2014 at 9:00 AM, Sa Li wrote: > >> Hi, all >> >> I am installing kafka-web-console on ubuntu server, when I sbt package it, >> it stuck on waiting for ivy.lock >> >> root@DO-mq-dev:/home/stuser/kafkaprj/kafka-web-console# sbt package >> Loading /usr/share/sbt/bin/sbt-launch-lib.bash >> [info] Loading project definition from >> /home/stuser/kafkaprj/kafka-web-console/project >> Waiting for lock on /root/.ivy2/.sbt.ivy.lock to be available... >> >> any idea? and any suggestion while further install. >> >> >> thanks >> >> >> Alec >> >> >> >> >> >>
Re: kafka-web-console
Hi, I am sure you must have got it running by now, but in case you gave up earlier, just have patience and it will start. Even I had faced this issue. The console takes a lot of time to start, but eventually it does. So this is not an error :) Hope this helped, -Palak On Sat, Oct 11, 2014 at 9:00 AM, Sa Li wrote: > Hi, all > > I am installing kafka-web-console on ubuntu server, when I sbt package it, > it stuck on waiting for ivy.lock > > root@DO-mq-dev:/home/stuser/kafkaprj/kafka-web-console# sbt package > Loading /usr/share/sbt/bin/sbt-launch-lib.bash > [info] Loading project definition from > /home/stuser/kafkaprj/kafka-web-console/project > Waiting for lock on /root/.ivy2/.sbt.ivy.lock to be available... > > any idea? and any suggestion while further install. > > > thanks > > > Alec > > > > > >
kafka-web-console
Hi, all I am installing kafka-web-console on ubuntu server, when I sbt package it, it stuck on waiting for ivy.lock root@DO-mq-dev:/home/stuser/kafkaprj/kafka-web-console# sbt package Loading /usr/share/sbt/bin/sbt-launch-lib.bash [info] Loading project definition from /home/stuser/kafkaprj/kafka-web-console/project Waiting for lock on /root/.ivy2/.sbt.ivy.lock to be available... any idea? and any suggestion while further install. thanks Alec
Re: Announcing Kafka Web Console v2.0.0
Awesome Claude, thanks! /*** Joe Stein Founder, Principal Consultant Big Data Open Source Security LLC http://www.stealth.ly Twitter: @allthingshadoop <http://www.twitter.com/allthingshadoop> / On Tue, Jun 24, 2014 at 10:57 AM, Claude Mamo wrote: > Announcing the second major release of Kafka Web Console: > https://github.com/claudemamo/kafka-web-console/releases/tag/v2.0.0. > Highlights: > > - I've borrowed some ideas from Kafka Offset Monitor and added graphs to > show the history of consumers offsets and lag as well as message throughput > > - Added partition leaders, log size, offset and lag > > - Bug fixes! > > Claude >
Announcing Kafka Web Console v2.0.0
Announcing the second major release of Kafka Web Console: https://github.com/claudemamo/kafka-web-console/releases/tag/v2.0.0. Highlights: - I've borrowed some ideas from Kafka Offset Monitor and added graphs to show the history of consumers offsets and lag as well as message throughput - Added partition leaders, log size, offset and lag - Bug fixes! Claude
Re: Kafka Web Console
Great! On Thu, Mar 6, 2014 at 12:35 AM, Dan Hoffman wrote: > Claude, > > FYI I've submitted a few issues for you to look at/consider. > > Dan > > On Saturday, March 1, 2014, Claude Mamo wrote: > > > Announcing the first release of Kafka Web Console: > > https://github.com/claudemamo/kafka-web-console/tree/v1.0. Tested on > > Chrome. > > > > Enjoy, > > > > Claude > > > -- -- Klaus Schaefers Senior Optimization Manager Ligatus GmbH Hohenstaufenring 30-32 D-50674 Köln Tel.: +49 (0) 221 / 56939 -784 Fax: +49 (0) 221 / 56 939 - 599 E-Mail: klaus.schaef...@ligatus.com Web: www.ligatus.de HRB Köln 56003 Geschäftsführung: Dipl.-Kaufmann Lars Hasselbach, Dipl.-Kaufmann Klaus Ludemann, Dipl.-Wirtschaftsingenieur Arne Wolter
Re: Kafka Web Console
Claude, FYI I've submitted a few issues for you to look at/consider. Dan On Saturday, March 1, 2014, Claude Mamo wrote: > Announcing the first release of Kafka Web Console: > https://github.com/claudemamo/kafka-web-console/tree/v1.0. Tested on > Chrome. > > Enjoy, > > Claude >
Re: Kafka Web Console
Hi Tomàs, just create a *lib* dir in kafka-web-console's root directory and put in the necessary JARs, Play will take care of the rest: http://www.playframework.com/documentation/2.0/Anatomy. Claude On Wed, Mar 5, 2014 at 10:50 AM, Tomas Nunez wrote: > Hi > > This is a n00b question. > > How do I install it? I'm trying to use it with mysql but sbt start says > "Caused by: java.lang.ClassNotFoundException: com.mysql.jdbc.Driver". I > have a /usr/share/java/mysql-connector-java.jar file and > /usr/share/java/mysql.jar. As it wasn't working, thought about putting that > jar in the project lib directory, but there is no lib dir (and no jar, > either!). S... I'm kind of lost. A little push, please? How can I make > the jdbc driver available for this project? > > Thanks, > Tomàs > > > > On Sun, Mar 2, 2014 at 10:53 AM, Claude Mamo > wrote: > > > Andrew, can you open an issue ( > > https://github.com/claudemamo/kafka-web-console/issues) for this? This > > should be a relatively small change and I'll try to include it in the > minor > > release that should come out this month. > > > > Claude > > > > > > On Sat, Mar 1, 2014 at 11:23 PM, Andrew Rudenko > > wrote: > > > > > Great! But i can't connect to our cluster :) Because web console do not > > > support standard zkConnect feature chroot, like localhost:2181/events > > > > > > On 02 Mar 2014, at 00:09, Claude Mamo wrote: > > > > > > > Announcing the first release of Kafka Web Console: > > > > https://github.com/claudemamo/kafka-web-console/tree/v1.0. Tested on > > > > Chrome. > > > > > > > > Enjoy, > > > > > > > > Claude > > > > > > > > > > -- > > > -- > > > >
Re: Kafka Web Console
Hi This is a n00b question. How do I install it? I'm trying to use it with mysql but sbt start says "Caused by: java.lang.ClassNotFoundException: com.mysql.jdbc.Driver". I have a /usr/share/java/mysql-connector-java.jar file and /usr/share/java/mysql.jar. As it wasn't working, thought about putting that jar in the project lib directory, but there is no lib dir (and no jar, either!). S... I'm kind of lost. A little push, please? How can I make the jdbc driver available for this project? Thanks, Tomàs On Sun, Mar 2, 2014 at 10:53 AM, Claude Mamo wrote: > Andrew, can you open an issue ( > https://github.com/claudemamo/kafka-web-console/issues) for this? This > should be a relatively small change and I'll try to include it in the minor > release that should come out this month. > > Claude > > > On Sat, Mar 1, 2014 at 11:23 PM, Andrew Rudenko > wrote: > > > Great! But i can't connect to our cluster :) Because web console do not > > support standard zkConnect feature chroot, like localhost:2181/events > > > > On 02 Mar 2014, at 00:09, Claude Mamo wrote: > > > > > Announcing the first release of Kafka Web Console: > > > https://github.com/claudemamo/kafka-web-console/tree/v1.0. Tested on > > > Chrome. > > > > > > Enjoy, > > > > > > Claude > > > > > -- --
Re: Kafka Web Console
Andrew, can you open an issue ( https://github.com/claudemamo/kafka-web-console/issues) for this? This should be a relatively small change and I'll try to include it in the minor release that should come out this month. Claude On Sat, Mar 1, 2014 at 11:23 PM, Andrew Rudenko wrote: > Great! But i can't connect to our cluster :) Because web console do not > support standard zkConnect feature chroot, like localhost:2181/events > > On 02 Mar 2014, at 00:09, Claude Mamo wrote: > > > Announcing the first release of Kafka Web Console: > > https://github.com/claudemamo/kafka-web-console/tree/v1.0. Tested on > > Chrome. > > > > Enjoy, > > > > Claude > >
Re: Kafka Web Console
Great! But i can’t connect to our cluster :) Because web console do not support standard zkConnect feature chroot, like localhost:2181/events On 02 Mar 2014, at 00:09, Claude Mamo wrote: > Announcing the first release of Kafka Web Console: > https://github.com/claudemamo/kafka-web-console/tree/v1.0. Tested on > Chrome. > > Enjoy, > > Claude
Re: Kafka Web Console
Thanks Claude, the screen shots look awesome! I will deploy and check it out on some environments. /*** Joe Stein Founder, Principal Consultant Big Data Open Source Security LLC http://www.stealth.ly Twitter: @allthingshadoop <http://www.twitter.com/allthingshadoop> / On Sat, Mar 1, 2014 at 10:09 AM, Claude Mamo wrote: > Announcing the first release of Kafka Web Console: > https://github.com/claudemamo/kafka-web-console/tree/v1.0. Tested on > Chrome. > > Enjoy, > > Claude >
Kafka Web Console
Announcing the first release of Kafka Web Console: https://github.com/claudemamo/kafka-web-console/tree/v1.0. Tested on Chrome. Enjoy, Claude
Re: Kafka Web Console
Sure Swapnil, I'll do that. On Tue, Apr 30, 2013 at 1:43 PM, Swapnil Ghike wrote: > Hi Samir, > > https://issues.apache.org/jira/browse/KAFKA-266 has been filed for this > purpose. We haven't made substantial progress yet, but seems like Guy was > working on it. Would you mind putting a comment on the JIRA? > > > Thanks, > Swapnil > > On 4/30/13 12:18 AM, "Samir Madhavan" > wrote: > > >Hi, > > > >Wanted to know if Kafka had web console to see what are the existing > >topics. How many messages have been received by the producer, How many > >have > >been consumed by a consumer or anything else for monitoring. > > > >Regards, > >Samir > > -- *Samir Madhavan *| Data Scientist | Flutura Business Solutions Pvt. Ltd | 4th Floor, 'Geetanjali', #693, 15th Cross, J.P Nagar 2nd Phase, Bangalore, India - 560078 | Mobile: +91 9886139631 | email: * samir.madha...@fluturasolutions.com*| www.fluturasolutions.com |
Re: Kafka Web Console
Hi Samir, https://issues.apache.org/jira/browse/KAFKA-266 has been filed for this purpose. We haven't made substantial progress yet, but seems like Guy was working on it. Would you mind putting a comment on the JIRA? Thanks, Swapnil On 4/30/13 12:18 AM, "Samir Madhavan" wrote: >Hi, > >Wanted to know if Kafka had web console to see what are the existing >topics. How many messages have been received by the producer, How many >have >been consumed by a consumer or anything else for monitoring. > >Regards, >Samir
Kafka Web Console
Hi, Wanted to know if Kafka had web console to see what are the existing topics. How many messages have been received by the producer, How many have been consumed by a consumer or anything else for monitoring. Regards, Samir
