I found kafka lsot message

2016-10-07 Thread yangyuqi
Hello every body,I build a kafka cluster(include 5 domains) use kafka_2.11-0.10.0.0 and kafka-python-1.3.1.I create a topic by 100 partitions and 2 replicate, then use 20 consumers to receive message. But, I found sometime the kafka lost message! I found some partition's offsite lost at

回复:Re: Re: I found kafka lsot message

2016-10-13 Thread yangyuqi
Other question: if account of consumer over broker number, whether loss data? if some broker rebooted, whether loss data? Thanks. - 原始邮件 - 发件人:Guozhang Wang 收件人:yangy...@sina.com 抄送人:users 主题:Re: Re: I

回复:Re: I found kafka lsot message

2016-10-10 Thread yangyuqi
Hi Guozhang, At first, thank you answer my question, and give me some suggest.But, I'm sure I readed some introduction about kafka. In my producer, My Code is( c code):res = rd_kafka_conf_set(kafka_conf, "request.required.acks", "-1", NULL, 0);res = rd_kafka_topic_conf_set( topic_conf,