Sweet! That was an easy one! Here's a jira for it:
https://issues.apache.org/jira/browse/KAFKA-903
thanks,
rob
-Original Message-
From: Jun Rao
Sent: Friday, May 10, 2013 10:53 PM
To: users@kafka.apache.org
Subject: Re: [0.8] exception running on windows when attempting to se
It seems this is because we hardcoded "/" in HighwaterMarkCheckpoint. Could
you file a jira?
val name = path + "/" + HighwaterMarkCheckpoint.highWatermarkFileName
Thanks,
Jun
On Fri, May 10, 2013 at 5:38 PM, Rob Withers wrote:
> Jun, thanks! I changed the properties for the broker to the
Jun, thanks! I changed the properties for the broker to the following,
worked, and I was able to produce data, for a while. More on the next issue
below.
thanks,
rob
...I changed the broker properties to the following:
for broker 0:
props.setProperty("log.dir", "\\tmp\\kafka0-logs");
for br
You are missing the jopt-simple jar.
Thanks,
Jun
On Wed, May 8, 2013 at 11:03 PM, Rob Withers wrote:
> I am running on windows. I am programmatically (no scripts) starting a zk,
> 2 brokers, 2 consumers and a producer, in this order but the first 3 at
> once, then the other 3 at once, all wi
I am running on windows. I am programmatically (no scripts) starting a zk,
2 brokers, 2 consumers and a producer, in this order but the first 3 at
once, then the other 3 at once, all with a nonexistent topic.
Here's the pertinent log for the producer (with other stuff mixed in, no
doubt):