Re: Subscribe me

Hello, it is actually self-service: https://kafka.apache.org/contact.html On Mon, Jan 13, 2014 at 5:42 PM, Matan Amir wrote: > Please subscribe me. > -- -- Guozhang

Re: custom kafka consumer - strangeness

So, you implemented your own consumer client using netty? Thanks, Jun On Mon, Jan 13, 2014 at 8:42 AM, Gerrit Jansen van Vuuren < gerrit...@gmail.com> wrote: > I'm using netty and async write, read. > For read I used a timeout such that if I do not see anything on the read > channel, my read f

Subscribe me

Please subscribe me.

Re: Killing broker leader

I am not sure but this may be same scenario as described in https://issues.apache.org/jira/browse/KAFKA-1193 On Tue, Jan 14, 2014 at 2:36 AM, Guozhang Wang wrote: > When the producer have exhausted all retries on sending, the data will be > dropped on the floor. One possible reason for this to

Re: [Kafka-users] badversion exception and unable to recover

Hello Bo, Doing 1 should be good enough under normal operations. Did you see any errors/exceptions on the controller log regarding partition reassignment? Guozhang On Mon, Jan 13, 2014 at 6:18 AM, Yu Bo(技术中心) wrote: > Hi all > Because of badversion exception, the id 1 broker is not a leader.

Re: Killing broker leader

When the producer have exhausted all retries on sending, the data will be dropped on the floor. One possible reason for this to happen is the leader failover taking long to let producer fails all 3 retries. You may want to tune the following two configs on producers ( https://kafka.apache.org/docu

RE: Looks like consumer fetchers get stopped we are not getting any data

We are using 0.8-beta. -Original Message- From: Guozhang Wang [mailto:wangg...@gmail.com] Sent: Sunday, January 12, 2014 8:21 PM To: users@kafka.apache.org Subject: Re: Looks like consumer fetchers get stopped we are not getting any data This might be a issue of KAFKA-992. The title only

Re: custom kafka consumer - strangeness

I'm using netty and async write, read. For read I used a timeout such that if I do not see anything on the read channel, my read function times out and returns null. I do not see any error on the socket, and the same socket is used throughout all of the fetches. I'm using the console producer and

Re: custom kafka consumer - strangeness

I can't seen to find the log trace for the timed out fetch request (every fetch request seems to have a corresponding completed entry). For the timed out fetch request, is it that the broker never completed the request or is it that it just took longer than the socket timeout to finish processing t

[Kafka-users] badversion exception and unable to recover

Hi all Because of badversion exception, the id 1 broker is not a leader. But the kafka thread on that server is already in work. The id 1 broker is only for replication. I want to recover the id 1 broker and became a leader. I had done : 1、 use the “kafka-reassign-partitions.sh” to remove the b

Re: Spring Integration Kafka support

Hi Preetham, We are able to successfully use spring-integration-kafka with non-zero broker ids without any issues. Could you provide more details on what exactly problem/error you are getting.? Also, You can try this examples under samples

Re: Kafka with Docker - producer disconnecting

thanks for these replies. I have zk and Kafka in separate dockers which is a little different than this example. However, I've seen similar behavior on my desktop running them normally when I only background zk and producer instead of redirecting the output, so this might be unrelated to docker.

Re: Killing broker leader

Yes, i have this message : ERROR Error in handling batch of 1 events (kafka.producer.async.ProducerSendThread) kafka.common.FailedToSendMessageException: Failed to send messages after 3 tries. On Sun, Jan 12, 2014 at 10:17 PM, Guozhang Wang wrote: > On the producer client log, did you see so

Re: Velocity on local machine

Hi, I am using kafka-0.8.0-src. Cheers, Klaus On Fri, Jan 10, 2014 at 8:48 PM, Neha Narkhede wrote: > What version of Kafka are you benchmarking? > > > On Fri, Jan 10, 2014 at 8:36 AM, Klaus Schaefers < > klaus.schaef...@ligatus.com> wrote: > > > Hi, > > > > during my test cpu load is quite l