Broker heap size

2017-03-23 Thread Avi Asulin
Hi , Is it normal for broker to have high heap size in use in my case 7GB out of 8GB or does it suggests there is a configuration/hardware issue? Thanks Avi

Kafka Replication Factor

2016-07-24 Thread Avi Asulin
Hi All Just double checking If i have created a topic with replication factor 1 does it mean i dont have replication if one of my disks crashes do i loose data? Thanks Avi

Error closing Socet for ...

2016-06-19 Thread Avi Asulin
Hi We are using kafka 0.8.2 with scala 2.10 version We currently have 3 brokers and we are working with ~ 170 producers We frequently get the Error ERROR Closing socket for /170.144.181.50 because of error (kafka.network.Processor) java.io.IOException: Connection reset by peer at sun.nio.c

Updating Consumer offset

2016-03-28 Thread Avi Asulin
Hi I am trying to update consumer offset to it initial offset in the zookeeper in order to consume data from beginning what should be the initial value of an offset is it 0 ,-1 ...? Thanks Avi