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]
