Sorry for the false alarm. The issue was that I was sending the messages multiple times. Fixed the same, and it seems to be working fine. Shall submit the patch on S4-7.
Thanks Karthik On Tue, Jan 3, 2012 at 11:52 AM, Karthik Kambatla <[email protected]>wrote: > Hi there > > S4-7 corresponds to making Netty robust. As we have discussed on the JIRA > - https://issues.apache.org/jira/browse/S4-7, I have implemented the > proposed approach - my github branch for the same - > https://github.com/kambatla/s4-piper/tree/s4-7 > > However, I am facing a couple of issues - > > 1. On send(), netty throws a callback for channels that I have no clue > about. I do some book-keeping for the channels I use, and the Channel that > Netty throws at me, I don't have any records. > 2. I have written a bunch of tests - guaranteed message delivery, > message ordering on both single and multiple partitions using zookeeper and > they all run fine. However, my code fails the WordCountTestZk test, I so > far have not been able to figure out why. > > Please comment if you know what might be causing any of these two issues. > Also, in light of #2, I am considering re-engineering the solution. So, > please comment on better ways to go about the problem at hand. > > Thanks > Karthik >
