kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ? ? <funk...@live.com>
Subject when use kafka streams to(topic) method sometime throw error?
Date Tue, 06 Mar 2018 03:23:42 GMT

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

________________________________
funkyyj@live.com

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message