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 <nit.dgp...@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 .....
>
