Mirror maker: New Producer error callback

2015-06-29 Thread Chittaranjan Hota
Hi Contributors, Not sure if any enhancement has been thought in this area. File: https://github.com/apache/kafka/blob/trunk/core/src/main/scala/kafka/producer/BaseProducer.scala (Line 44) Currently, in the mirror maker process all async Producer send calls have ErrorLoggingCallback registered. T

Re: NIO and Threading implementation

2015-01-21 Thread Chittaranjan Hota
are you skepticism of that call. I'm not sure why it is there > or if it is needed. I agree that wakeup should only be needed from other > threads. It would be good to untangle that mystery. I wonder what happens > if it is removed. > > -Jay > > On Wed, Jan 21, 2015 at 1

NIO and Threading implementation

2015-01-21 Thread Chittaranjan Hota
Hello, Congratulations to the folks behind kafka. Its has been a smooth ride dealing with multi TB data when the same set up in JMS fell apart often. Although I have been using kafka for more than a few days now, started looking into the code base since yesterday and already have doubts at the ver