Kafka unable to process large number of messages

2013-03-29 Thread anand nalya
Hi, I'm running kafka in distributed mode with 2 nodes. It works fine with slow ingestion rates but when I increase the ingestion rate, both the nodes starts giving the following error: [2013-03-29 14:51:45,379] ERROR Closing socket for /192.168.145.183 because of error (kafka.network.Processor)

Re: Kafka unable to process large number of messages

2013-03-29 Thread Jun Rao
This indicates that the messages sent to the broker are somehow corrupted. Are you using a java producer? How many instances of producers do you have? Thanks, Jun On Fri, Mar 29, 2013 at 2:46 AM, anand nalya anand.na...@gmail.com wrote: Hi, I'm running kafka in distributed mode with 2

Re: Can't use ':' in client name?

2013-03-29 Thread Jun Rao
Chris, Client id is used for registering jmx beans for monitoring. Because of the restrictions in bean names, we limit the client id to be only alpha-numeric plus - and _. Thanks, Jun On Fri, Mar 29, 2013 at 5:54 AM, Chris Curtin curtin.ch...@gmail.comwrote: Hi, Before I submit an

Re: Kafka wiki Documentation conventions - looking for feedback

2013-03-29 Thread Chris Curtin
Hi, I've added an example program for using a SimpleConsumer for 0.8.0. Turns out to be a little more complicated once you add Broker failover. I'm not 100% thrilled with how I detect and recover, so if someone has a better way of doing this please let me (and this list) know.

Hardware profile

2013-03-29 Thread Ian Friedman
Hi all, I'm wondering how up to date the hardware specs listed on this page are: https://cwiki.apache.org/confluence/display/KAFKA/Operations We're evaluating hardware for a Kafka broker/ZK quorum buildout and looking for some tips and/or sample configurations if anyone can help us out with

Fwd: kafka appender layout does not work for kafka 0.7.1

2013-03-29 Thread Sining Ma
Hi I am using kafka 0.7.1 right now. I am using the following log4j properties file and trying to send some log information to kafka server. log4j.rootLogger=INFO,file,stdout log4j.appender.stdout=org.apache.log4j.ConsoleAppender log4j.appender.stdout.layout=org.apache.log4j.PatternLayout

Re: Hardware profile

2013-03-29 Thread Neha Narkhede
1. We never share zookeeper and broker on the same hardware. Both need significant memory to operate efficiently. 2. 14 drive setup is just for Kafka. We have a separate disk for the OS, AFAIK. Thanks, Neha On Fri, Mar 29, 2013 at 11:37 AM, Ian Friedman i...@flurry.com wrote: Thanks Jun. Couple

Re: Hardware profile

2013-03-29 Thread David Arthur
How many brokers are you (LinkedIn) running? What kind of network topology? On 3/29/13 2:45 PM, Neha Narkhede wrote: 1. We never share zookeeper and broker on the same hardware. Both need significant memory to operate efficiently. 2. 14 drive setup is just for Kafka. We have a separate disk for

Linux Packages

2013-03-29 Thread mrevilgnome
Has anyone gone through the effort of packaging Kafka for Ubuntu, Debian, or CentOS? I'm partially through the process for Ubuntu, and I figured I should ask. Thanks. --Matt

Re: Linux Packages

2013-03-29 Thread Jonathan Creasy
We have EL6 packages. On Fri, Mar 29, 2013 at 2:01 PM, mrevilgnome mrevilgn...@gmail.com wrote: Has anyone gone through the effort of packaging Kafka for Ubuntu, Debian, or CentOS? I'm partially through the process for Ubuntu, and I figured I should ask. Thanks. --Matt -- **

More SocketTimeoutExceptions

2013-03-29 Thread Bob Jervis
I now have the following settings (in various configs): In our producer configs: producer.request.timeout.ms=60 This producer just hangs there for 10 minutes before timing out Here is the stack dump for that timeout: java.net.SocketTimeoutException at

Re: Linux Packages

2013-03-29 Thread Manish Bhatt
BTW, here is how one guy did it. He rebuilds the upstream tarball after the build so there is no discrepancy for the debian build packaging scripts. https://github.com/wikimedia-incubator/kafka-debian On Fri, Mar 29, 2013 at 3:41 PM, Manish Bhatt mbh...@imvu.com wrote: We are trying that

Re: kafka appender layout does not work for kafka 0.7.1

2013-03-29 Thread Jun Rao
Kafka log4j appender may not support the layout. Could you open a jira for this? Thanks, Jun On Fri, Mar 29, 2013 at 11:24 AM, Sining Ma sinin...@aol.com wrote: Hi I am using kafka 0.7.1 right now. I am using the following log4j properties file and trying to send some log information to

Re: Hardware profile

2013-03-29 Thread Jun Rao
We have multiple Kafka clusters, each has about 10 brokers right now. Not sure about the network topology. What kind of info do you want to know? Thanks, Jun On Fri, Mar 29, 2013 at 11:47 AM, David Arthur mum...@gmail.com wrote: How many brokers are you (LinkedIn) running? What kind of

Re: More SocketTimeoutExceptions

2013-03-29 Thread Jun Rao
This means that somehow the broker is not sending the response to the producer and is sending it back to the wrong client. Any error in the broker log? Thanks, Jun On Fri, Mar 29, 2013 at 3:35 PM, Bob Jervis bjer...@gmail.com wrote: I now have the following settings (in various configs):

Re: Hardware profile

2013-03-29 Thread David Arthur
Especially in light of replication (broker-broker communication), I'm wondering if all the brokers are in the same rack and what kind of networking interfaces are used (Gigabit ethernet, Fibre Channel, etc). On 3/29/13 6:53 PM, Jun Rao wrote: We have multiple Kafka clusters, each has about 10

Re: Hardware profile

2013-03-29 Thread Neha Narkhede
gigabit ethernet Thanks, Neha On Fri, Mar 29, 2013 at 4:44 PM, David Arthur mum...@gmail.com wrote: Especially in light of replication (broker-broker communication), I'm wondering if all the brokers are in the same rack and what kind of networking interfaces are used (Gigabit ethernet, Fibre