Yes. True. Thanks for your help.
> Date: Tue, 11 Mar 2014 11:48:20 -0700
> Subject: Re: Remote Zookeeper
> From: b...@b3k.us
> To: users@kafka.apache.org
>
> If they are on different physical machines then binding to localhost/using
> localhost as the host name is unlikel
e on 3 different physical
> machines.
>
> > From: b...@b3k.us
> > Date: Tue, 11 Mar 2014 10:58:50 -0700
> > Subject: Re: Remote Zookeeper
> > To: users@kafka.apache.org
> >
> > "I'd suggest deleting the zookeeper and Kafka logs and starting o
above worked for me.
> From: andthereitg...@hotmail.com
> To: users@kafka.apache.org
> Subject: RE: Remote Zookeeper
> Date: Tue, 11 Mar 2014 18:18:31 +
>
> Thanks. I already checked out the wiki and step 6 in particular.
> Just to clarify, Zk, Broker1 and Broker2 a
Thanks. I already checked out the wiki and step 6 in particular.
Just to clarify, Zk, Broker1 and Broker2 are on 3 different physical machines.
> From: b...@b3k.us
> Date: Tue, 11 Mar 2014 10:58:50 -0700
> Subject: Re: Remote Zookeeper
> To: users@kafka.apache.org
>
> "I
/ids/1
> with address localhost:9092. (kafka.utils.ZkUtils$)
> [2014-03-11 12:07:21,096] INFO [Kafka Server 1], Connecting to ZK:
> 192.168.1.120:2181 (kafka.server.KafkaServer)
> [2014-03-11 12:07:21,222] INFO Will not load MX4J, mx4j-tools.jar is not
> in the classpath (kafka.uti
tils$)
[2014-03-11 12:07:21,469] INFO [Kafka Server 1], Started
(kafka.server.KafkaServer)
Could this be an issue?
INFO Registered broker 2 at path /brokers/ids/2 with address localhost:9092.
INFO Registered broker 1 at path /brokers/ids/1 with address localhost:9092.
> Date: Tu
rNotAvailableException}] for topic [test-rep]: class
> kafka.common.LeaderNotAvailableException
> (kafka.producer.BrokerPartitionInfo)
>
>
>
>
> > Date: Tue, 11 Mar 2014 09:05:54 -0700
> > Subject: Re: Remote Zookeeper
> > From: pradeep...@gmail.com
>
a
for topic test-rep ->
No partition metadata for topic test-rep due to
kafka.common.LeaderNotAvailableException}] for topic [test-rep]: class
kafka.common.LeaderNotAvailableException (kafka.producer.BrokerPartitionInfo)
> Date: Tue, 11 Mar 2014 09:05:54 -0700
> Subject: Re: Re
pply(ProducerSendThread.scala:67)
> at scala.collection.immutable.Stream.foreach(Stream.scala:254)
> at
> kafka.producer.async.ProducerSendThread.processEvents(ProducerSendThread.scala:66)
> at
> kafka.producer.async.ProducerSendThread.run(ProducerSendT
sync.ProducerSendThread.run(ProducerSendThread.scala:44)
From: andthereitg...@hotmail.com
To: users@kafka.apache.org
Subject: RE: Remote Zookeeper
Date: Tue, 11 Mar 2014 15:59:44 +
Okay thanks. Just to verify my setup I tried the following on broker1 (by
publishing to localhost)
$KAFKA_HOME/bin/kafka-c
-list
localhost:9092,192.168.1.123:9092 --topic test
Didn't work. I either get connection refused or no route to host exceptions.
> Date: Tue, 11 Mar 2014 08:38:22 -0700
> Subject: Re: Remote Zookeeper
> From: b...@b3k.us
> To: users@kafka.apache.org
>
> That's not
at scala.collection.immutable.Stream.foreach(Stream.scala:254)
> at
> kafka.producer.async.ProducerSendThread.processEvents(ProducerSendThread.scala:66)
> at
> kafka.producer.async.ProducerSendThread.run(ProducerSendThread.scala:44)
>
> What am I missing?
>
>
Thread.scala:44)
What am I missing?
> From: andthereitg...@hotmail.com
> To: users@kafka.apache.org
> Subject: RE: Remote Zookeeper
> Date: Tue, 11 Mar 2014 02:29:34 +
>
> Thanks. Totally missed that.
>
> > From: b...@b3k.us
> > Date: Mon, 10 Mar 2014 19
Thanks. Totally missed that.
> From: b...@b3k.us
> Date: Mon, 10 Mar 2014 19:18:50 -0700
> Subject: Re: Remote Zookeeper
> To: users@kafka.apache.org
>
> zookeeper.connect
>
> https://kafka.apache.org/08/configuration.html
>
>
> On Mon, Mar 10, 2014
remote zookeper server?
>
> I am using $KAFKA/kafka-server-start.sh $KAFKA_CONFIG/server.properties
> on both the brokers to start them up
> and I have a remote zookeeper running at 192.168.1.120
>
> Can anyone help?
>
> A
>
>
and I have a remote zookeeper running at 192.168.1.120
Can anyone help?
A
16 matches
Mail list logo
