Hello,
during our resilience tests, a message is logged with an error. The log line is
the following:
2019-02-25 14:18:35.100+ [kafka-producer-network-thread |
str1-StreamThread-1-producer] ERROR o.a.k.s.p.i.RecordCollectorImpl - task
[0_0] Error sending record (key \x003\x9F\xF0 value [10
enario.
>
> -Matthias
>
> On 11/30/18 12:57 AM, Yoshimo wrote:
>
> > Hello Kafka users,
> > I am currently building a Kafka Streams application and I am using a
> > transform step with two KeyValue stores, one containing the transformed
> > message and the second on
Hello Kafka users,
I am currently building a Kafka Streams application and I am using a transform
step with two KeyValue stores, one containing the transformed message and the
second one some metadata about the message.
In the transform step I first update the metadata store and then store the