AdminUtils.addPartitions

2016-01-07 Thread Ofra Pavlovitz
Hi, I'm looking for the syntax of the replicaAssignmentStr parameter of the method AdminUtils.addPartitions. For example, suppose I have brokers 0..5 and topic T with 2 partitions and replication factor 3. And I would like to add 2 more partitions with replicas on brokers 1,3,5. What should be the

Re: session.timeout.ms limit

2016-03-06 Thread Ofra Pavlovitz
Hi Vanessa, The workaround we use in this case is closing the consumer and then opening it again when required. In addition you can increase the heartbeat timeout (heartbeat.interval.ms) - see more details in the documentaton. Thanks, Ofra 2016-03-02 16:09 GMT+02:00 Gligor Vanessa : > Hello, >