From ae42c7f04260ebd72eeca9e98f58d50c31526af4 Mon Sep 17 00:00:00 2001 From: Chris Mikkelson Date: Tue, 30 Jun 2026 09:24:40 -0500 Subject: [PATCH] Handle fragmented containers in zmq, kafka inputs Properly propagate the `nmsg_res_again` return of _input_nmsg_unpack_container through _input_process_buffer_into_container. --- nmsg/input_nmsg.c | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/nmsg/input_nmsg.c b/nmsg/input_nmsg.c index 08b8592c..839098ee 100644 --- a/nmsg/input_nmsg.c +++ b/nmsg/input_nmsg.c @@ -390,7 +390,7 @@ _input_process_buffer_into_container(nmsg_input_t input, Nmsg__Nmsg **nmsg, uint /* expire old outstanding fragments */ _input_frag_gc(input->stream); - return nmsg_res_success; + return (res); } #endif /* defined(HAVE_LIBRDKAFKA) || defined(HAVE_LIBZMQ) */