at-least-once delivery

2016-01-30 Thread Franco Giacosa
Hi, The at-least-once delivery is generated in part by the network fails and the retries (that may generate duplicates) right? In the event of a duplicated (there was an error but the first message landed ok on the partition P1) the producer will recalculate the partition on the retry? is this do

Re: at-least-once delivery

2016-01-30 Thread Franco Giacosa
Sorry, this solved my questions: "Setting a value greater than zero will cause the client to resend any record whose send fails with a potentially transient error. Note that this retry is no different than if the client resent the record upon receiving the error. Allowing retries will potentially c

ConsumerFetcherThread problem

2016-01-30 Thread Jayden Y. Jin
Hi I have some problem I have used kafka_2.9.1-0.8.2.2. kafka was operating normally about 2 weeks but I execute a command bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic I got error message 2016-01-30T11:07:14.058+0800 k.c.ConsumerFetcherThread [ERROR] [ConsumerFetcherThread

Re: at-least-once delivery

2016-01-30 Thread James Cheng
> On Jan 30, 2016, at 4:21 AM, Franco Giacosa wrote: > > Sorry, this solved my questions: "Setting a value greater than zero will > cause the client to resend any record whose send fails with a potentially > transient error. Note that this retry is no different than if the client > resent the rec