unable to connect to manual partitions

[Laxmi Narayan <ni...@gmail.com>]

Hi,

I am unable to connect to kafka individual partitions from different server,

while I am able to retrieve and connect to kafka and get partition size etc
from other

server.  I am able to connect to each partition from same server where
kafka is hosted.

Keep learning keep moving .....

Re: unable to connect to manual partitions

[Laxmi Narayan <ni...@gmail.com>]

​
 I am using below properties :

props.put("bootstrap.servers",
DataAppConfig.getInstance().getValue("bootstrap.servers"));
props.put("zookeeper.connect","zookeeper_host:2181");
props.put("enable.auto.commit",
DataAppConfig.getInstance().getValue("enable.auto.commit"));
//props.put("auto.commit.interval.ms",
KafkaConstants.Auto_Commit_Interval_Ms);
props.put("linger.ms", DataAppConfig.getInstance().getValue("linger.ms"));
props.put("acks", DataAppConfig.getInstance().getValue("acks"));
props.put("key.deserializer",
DataAppConfig.getInstance().getValue("key.deserializer"));
props.put("value.deserializer",
DataAppConfig.getInstance().getValue("value.deserializer"));
props.put("key.serializer",
DataAppConfig.getInstance().getValue("key.serializer"));
props.put("value.serializer",
DataAppConfig.getInstance().getValue("value.serializer"));
props.put("partitioner.class", DataAppConfig.getInstance().getValue("
kafka.partition.class.name"));​


Keep learning keep moving .....

On Wed, Aug 23, 2017 at 9:03 AM, Laxmi Narayan <ni...@gmail.com> wrote:

> Hi,
>
> I am unable to connect to kafka individual partitions from different
> server,
>
> while I am able to retrieve and connect to kafka and get partition size
> etc from other
>
> server.  I am able to connect to each partition from same server where
> kafka is hosted.
>
> Keep learning keep moving .....
>