Weird message sent to internal Streams topic

2019-02-26 Thread Yoshimo
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

Re: Partial updates in Kafka Streams stores

2018-11-30 Thread Yoshimo
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

Partial updates in Kafka Streams stores

2018-11-30 Thread Yoshimo
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