Re: Potential memory leak in rocksdb

2017-02-12 Thread Guozhang Wang
Pierre, Could you let me know what serdes do you use for the key-value pair of type ? I looked at the 0.10.1.1 code and did not find any obvious memory leak from Streams in its iterator implementation. One thing that I'm suspecting is that when returning the key-value pair, we call the serdes to

Re: Need help in understanding bunch of rocksdb errors on kafka_2.10-0.10.1.1

2017-02-12 Thread Guozhang Wang
Hi Sachin, About the CommitFailedException error and the potential memory leakage, I also would like to know which one may be causing the other. So is it: 1) You saw frequent CommitFailedException, and you handled them in the exception handler by re-creating the instances, and then you observe me

Re: Table a KStream

2017-02-12 Thread Elliot Crosby-McCullough
Thanks! On 11 February 2017 at 18:39, Eno Thereska wrote: > Yes you are correct Elliot. If you look at it just from the point of view > of what's in the topic, and how the topic is configured (e.g., with > "compact") there is no difference. > > > Thanks > Eno > > > On 11 Feb 2017, at 17:56, Elli

Re: log.flush.interval.messages setting of Kafka 0.9.0.0

2017-02-12 Thread +8618611626818
someone can help explain it? 发自我的超级手机 2016年12月16日 18:17于 Json Tu 写道: > > Hi all, > we have a cluster of 0.9.0.0 with 3 nodes, we have a topic with 3 replicas, > and send it with ack -1, our sending latency is avg 7ms. I prepare to > optimize performance of cluster through adjusting some params