Yes. It's a known bug. You can read details here: https://cwiki.apache.org/confluence/display/KAFKA/KIP-91+Provide+Intuitive+User+Timeouts+in+The+Producer
You can avoid it, by increasing the `request.timeout.ms` parameter for the producer. -Matthias On 3/5/18 9:46 PM, 杰 杨 wrote: > it seems i don't config ProducerConfig in stream application. > should I config that ? > > > > ________________________________ > [email protected] > > From: [email protected]<mailto:[email protected]> > Date: 2018-03-06 11:23 > To: users<mailto:[email protected]> > Subject: when use kafka streams to(topic) method sometime throw error? > > hi: > I meet a problem today. > when I use kafka stream to consumer one topic and do mapValues() method, > and to another topic then .sometimes throw an error > this is code sample: > new StreamsBuilder().stream(xxxtopic, Consumed.with(Serdes.String(), > Serdes.String())).mapValus(method).to(newTopic). > sometimes it's work well but sometime it's throw error > > to topic newTopic due to org.apache.kafka.common.errors.TimeoutException: > Expiring 6 record(s) for newTopic-2: 30030 ms has passed since last attempt > plus backoff time > > ________________________________ > [email protected] >
signature.asc
Description: OpenPGP digital signature
