connect icon indicating copy to clipboard operation
connect copied to clipboard

redis_streams with missing body_key in event stays in pending state

Open mannharleen opened this issue 3 years ago • 1 comments

Using benthos v4.3.0 Using redis

Issue: While using input.redis_streams, when specific body_key is not present on the stream event, the event is neither ACKed not NACKed.

Workaround: As soon as I switched it to an event.key that was always present in the event, it worked

mannharleen avatar Jul 22 '22 00:07 mannharleen

Hey @mannharleen are you able to provide more information such as the config you're seeing issues with? Do you get any interesting logs?

The field body_key is the key of the Redis object to set to the value of the message (as raw bytes), so it isn't dependent on the data that's inbound. For example, if you have a message payload of {"foo":"bar"} and a body_key set to baz then I would expect the following object to be created on the stream:

baz: "{\"foo\":\"bar\"}"

Jeffail avatar Jul 22 '22 07:07 Jeffail