kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From 杰 杨 <funk...@live.com>
Subject Re: when use kafka streams to(topic) method sometime throw error?
Date Tue, 06 Mar 2018 05:46:48 GMT
it seems i don't config ProducerConfig in stream application.
should I config that ?



________________________________
funkyyj@live.com

From: funkyyj@live.com<mailto:funkyyj@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

________________________________
funkyyj@live.com
Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message