Hi
I'm trying to upgrade a 0.7 kafka cluster, but I'm getting an error:
I created the file migrationToolConsumer.properties with just theinfo to
connect to the old cluster:
_
zookeeper.connect=zookeeper01:2181,zookeeper02:2181,zookeeper03:2181
group.id=migration.prod
__
Then the produce
issues.apache.org/jira/browse/KAFKA-760
May different versions of scala be the cause of this error? I just used
"./sbt update" to make sure...
If not, where should I find that class file?
Thanks again!
On Sat, Nov 1, 2014 at 4:05 AM, Tomas Nunez wrote:
> Hi
>
> I'm tryi
Alex you say hi :)
On Sat, Nov 1, 2014 at 4:32 AM, Gwen Shapira wrote:
> This is part of Scala, so it should be in the scala-library-...jar
>
>
> On Fri, Oct 31, 2014 at 8:26 PM, Tomas Nunez wrote:
>
> > Well... I used strace and I found it was looking for some classes in a
&g
ass, then?
I'm a bit lost... Is there any way I can run it with more verbose? Strace
is too verbose, "bash -x" is not that much. Something in between?
On Sat, Nov 1, 2014 at 4:53 AM, Gwen Shapira wrote:
> The file should be your Scala jar.
> You should have it in yo
l code and start adding LOG lines.
> > because there aren't enough of those to troubleshoot.
> >
> > On Wed, Nov 5, 2014 at 6:13 PM, Gwen Shapira
> > wrote:
> >
> >> org.apache.zookeeper.ClientCnxn is throwing the exception, so I'm 10
Hi
I'm new around here and I'm dealing with a problem, and reading the
documentation I don't know where else to look.
I have a cross-dc mirrormaker setup: Mirrormaker is consuming from 5
frontend servers in each DC (10 in total) and 5 backend servers are
consuming from mirrormaker. That's working
Thanks,
Jun
On Mon, Feb 10, 2014 at 4:28 PM, Tomas Nunez wrote:
> Hi
>
> I'm new around here and I'm dealing with a problem, and reading the
> documentation I don't know where else to look.
>
> I have a cross-dc mirrormaker setup: Mirrormaker is consuming fro
ache.org/confluence/display/KAFKA/FAQ#FAQ-IamusingtheZK-basedproducerin0.7andIseedataonlyproducedonsomeofthebrokers,butnotall,why
> ?
>
> Thanks,
>
> Jun
>
>
> On Mon, Feb 10, 2014 at 4:04 PM, Tomas Nunez wrote:
>
> > I don't see anything in kafabe03. In fact
Hi!
Sorry if this question has already been answered, but I've search the
archives, the project page and the wiki unsuccessfully.
I'd like to know the meaning of the jmx exposed metrics. I can guess based
on the name but I'd like to be sure. Plus, some of them seem to be reset
when I restart the
found in
>
> https://cwiki.apache.org/confluence/display/KAFKA/Operations#Operations-Monitoring
>
> Thanks,
>
> Jun
>
>
> On Tue, Feb 11, 2014 at 6:51 AM, Andrew Otto wrote:
>
> > Here tis!
> >
> > https://kafka.apache.org/documentation.html#monitor
> MessagesIn, right?
Thanks!
On Tue, Feb 11, 2014 at 5:35 PM, Tomas Nunez wrote:
> Yup... I read both of them, but I saw much more data in the jmx and I was
> trying to understant it to make the most of them :)
>
> But I'll settle knowing that is the useful data. Thank you both
x beans start from 0 on broker startup.
>
> Thanks,
> Neha
>
>
> On Tue, Feb 11, 2014 at 9:42 AM, Tomas Nunez wrote:
>
> > Then I guess mi next question is:
> > The jmx metric "Kafka -> kafka.BrokerTopicStat. ->
> MessagesIn"
> > counts
Or even simpler: Is there any way to know the number of messages in a
topic, in a server? Is that "kafka.logs.topic -> CurrentOffset"? If not,
what does that "CurrentOffset" means?
On Tue, Feb 11, 2014 at 7:08 PM, Tomas Nunez wrote:
> Yes, but this counts how many m
y)? We don't have that jmx right now, but it's probably
> useful to add one. We do have a jmx on # unconsumed messages for a given
> consumer.
>
> Thanks,
>
> Jun
>
>
> On Thu, Feb 13, 2014 at 5:18 AM, Tomas Nunez wrote:
>
> > Or even simpler: Is
Hi
This is a n00b question.
How do I install it? I'm trying to use it with mysql but sbt start says
"Caused by: java.lang.ClassNotFoundException: com.mysql.jdbc.Driver". I
have a /usr/share/java/mysql-connector-java.jar file and
/usr/share/java/mysql.jar. As it wasn't working, thought about putti
15 matches
Mail list logo
