it seems i don't config ProducerConfig in stream application. should I config that ?
________________________________ funk...@live.com From: funk...@live.com<mailto:funk...@live.com> Date: 2018-03-06 11:23 To: users<mailto:users@kafka.apache.org> 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 ________________________________ funk...@live.com
