-Re: Metadata API returns localhost.localdomain for one of the brokers in EC2
Aniket Bhatnagar 2013-10-03, 15:03
Thanks Jun and David.
I think the FAQ mentions why it's not possible to connect to broker from
outside. In my case, all servers (producers and brokers) are in the same
VPC. Call to InetAddress.getLocalHost.getHostAddress should return an
internal IP to which producers should be able to connect. The issue seems
to be that the call to InetAddress.getLocalHost.getHostAddress returns
and that too on just 1 broker. Any ideas on why that could be happening?
I can configure host.name property in broker config but its slightly
painful. I am curious to know what can cause
to return loopback addresses like localhost.localdomain so that other users
know why they really have to setup host.name in EC2 even if both producers
and consumers are in same VPC.
On 3 October 2013 19:56, Jun Rao <[EMAIL PROTECTED]> wrote:
> There is an FAQ too.
> On Thu, Oct 3, 2013 at 6:43 AM, David Arthur <[EMAIL PROTECTED]> wrote:
> > You can configure the hostname for the broker with the "host.name"
> > property in the broker's config (server.properties?). If you don't
> > one here, then all interfaces will be bound to and one will be chosen to
> > get published via ZooKeeper (what the metadata API is reading)
> > See: http://kafka.apache.org/**documentation.html#**brokerconfigs<
> > -David
> > On 10/3/13 2:57 AM, Aniket Bhatnagar wrote:
> >> I have installed 2 brokers on EC2. I also have a (scala) application
> >> receives data stream and pushes to kafka cluster. By co-incidence, a
> >> (slightly heavier) EC2 instance is running both a kafka broker and the
> >> data
> >> receiver application. I am noticing that all data receiver application
> >> nodes that are not on the shared kafka + reciever app EC2 instance are
> >> complaining for connect errors to localhost.localdomain:9092. Is this a
> >> possible bug that results in Kafka detecting instance hostname
> >> as localhost.localdomain instead of actual hostname?
> >> Also, how do I fix this temporarily until a permanent fix is available?