special characters in kafka log

2017-01-24 Thread Laxmi Narayan NIT DGP
Hi , Have anybody tested spcl char inside kafka ? I am little worried about serialization and de-serialization of special characters. *​* *Regards,* *Laxmi Narayan Patel* *MCA NIT Durgapur (2011-2014)* *Mob:-9741292048,8345847473*

min hardware requirement

2017-01-20 Thread Laxmi Narayan NIT DGP
Hi , what is min hardware requirement for kafka ? I see min ram size for production is recommended is 32GB. what can be issue with 8 GB ram and for test purpose i was planning to use some 1gb or 4gb aws machine, is it safe to run in 1gb machine for few days? For log write i have big disk.

Re: Error while fetching metadata only for one specific topic

2017-01-15 Thread Laxmi Narayan NIT DGP
,* *Laxmi Narayan Patel* *MCA NIT Durgapur (2011-2014)* *Mob:-9741292048,8345847473* On Mon, Jan 16, 2017 at 12:31 PM, Laxmi Narayan NIT DGP < nit.dgp...@gmail.com> wrote: > Hi , > > I am getting below error . > > WARN Error while fetching metadata with correlation

Error while fetching metadata only for one specific topic

2017-01-15 Thread Laxmi Narayan NIT DGP
Hi , I am getting below error . WARN Error while fetching metadata with correlation id 1 : {DeviceData=LEADER_NOT_AVAILABLE} (org.apache.kafka.clients.NetworkClient) *Regards,* *Laxmi Narayan Patel* *MCA NIT Durgapur (2011-2014)* *Mob:-9741292048,8345847473*

how to manage if zookeeper goes down

2017-01-12 Thread Laxmi Narayan NIT DGP
Hi, I have understood that zookeeper is responsible for runing kafka in cluster mode. But how do we ensure that zookeeper never goes down? *​​* *Regards,* *Laxmi Narayan Patel* *MCA NIT Durgapur (2011-2014)* *Mob:-9741292048,8345847473*

Re: can i delete topic like this ?

2017-01-12 Thread Laxmi Narayan NIT DGP
l doesn't look right. Port 9092 is kafka broker's default > listening port. Zookeeper's default is 2181. > > > On Thu, Jan 12, 2017 at 1:33 PM, Laxmi Narayan NIT DGP < > nit.dgp...@gmail.com > > wrote: > > > /bin/kafka-topics.sh --zookeeper localhost:9092 --d

can i delete topic like this ?

2017-01-12 Thread Laxmi Narayan NIT DGP
/bin/kafka-topics.sh --zookeeper localhost:9092 --delete --topic topicName I am getting exception saying : [2017-01-13 00:01:45,101] WARN Client session timed out, have not heard from server in 15016ms for sessionid 0x0 (org.apache.zookeeper.ClientCnxn) [2017-01-13 00:02:00,902] WARN Client

Re: adding more partition

2017-01-02 Thread Laxmi Narayan NIT DGP
=2947432 > <http://dl.acm.org/citation.cfm?id=2947432>* > *Blog:- **http://learnhardwithkunalgupta.blogspot.in > <http://learnhardwithkunalgupta.blogspot.in> * > > > > > > On Tue, Jan 3, 2017 at 12:41 PM, Laxmi Narayan NIT DGP < > nit.dgp...@gmail.com

Re: adding more partition

2017-01-02 Thread Laxmi Narayan NIT DGP
://dl.acm.org/citation.cfm?id=2947432 > <http://dl.acm.org/citation.cfm?id=2947432>* > *Blog:- **http://learnhardwithkunalgupta.blogspot.in > <http://learnhardwithkunalgupta.blogspot.in> * > > > > > > On Tue, Jan 3, 2017 at 12:25 PM, Laxmi Narayan NIT DGP < > nit.dg

adding more partition

2017-01-02 Thread Laxmi Narayan NIT DGP
Hi, Does adding more partitions to kafka will help in scaling ? *Regards,* *Laxmi Narayan Patel* *MCA NIT Durgapur (2011-2014)* *Mob:-9741292048,8345847473*