FYI, I've been able to hack into the DefaultEventHandler#handle() method with
AspectJ.
It's really dirty, but it works for the simplest cases.
https://gist.github.com/itaifrenkel/5427416
-Original Message-----
From: Itai Frenkel
Sent: Saturday, April 20, 2013 11:02 AM
ooked like extending DefaultEventHandler could do the
>> trick.
0.8 has the same DefaultEventHandler logic as 0.7, so can you try to do the
same in 0.8 ? We will make this easier to achieve in 0.9.
Thanks,
Neha
On Fri, Apr 19, 2013 at 2:25 PM, Itai Frenkel wrote:
> I would like to write a s
notify you of the status of
the messages. However, I think we want to rethink the client APIs for 0.9. Let
us know if you have feedback.
Thanks,
Neha
On Fri, Apr 19, 2013 at 4:15 AM, Itai Frenkel wrote:
> Could you give some pointers (or test case perhaps) how to detect that a
> messa
Could you give some pointers (or test case perhaps) how to detect that a
message was sent successfully to the broker, when sending the data
asynchronously?
-Original Message-
From: Swapnil Ghike [mailto:sgh...@linkedin.com]
Sent: Friday, April 19, 2013 10:24 AM
To: users@kafka.apache.or
Hello,
We're considering to use Kafka, and would like to know the Java/ Scala/Kafka
version combination in which it is being used in production.
The wiki "Operations" page states that "We are running Kafka 0.7 right now but
may move to trunk as we fix bugs."
While I read here that 0.8 was sched
Hello,
I am evaluating the usage of Kafka, and read the "Split brain problem: The
consumer rebalancing design suffers from a split brain problem" in
https://cwiki.apache.org/KAFKA/consumer-co-ordinator.html
My question is this - assuming I would like to have a single consumer per
topic, would I
