@@ -91,6 +91,8 @@ static char *get_group_metadata(void *chunk, size_t size)
9191 ret = flb_log_event_decoder_init (& log_decoder , chunk , size );
9292 TEST_CHECK (ret == FLB_EVENT_DECODER_SUCCESS );
9393
94+ flb_log_event_decoder_read_groups (& log_decoder , FLB_TRUE );
95+
9496 ret = flb_log_event_decoder_next (& log_decoder , & log_event );
9597 if (ret != FLB_EVENT_DECODER_SUCCESS ) {
9698 return NULL ;
@@ -112,6 +114,8 @@ static char *get_group_body(void *chunk, size_t size)
112114 ret = flb_log_event_decoder_init (& log_decoder , chunk , size );
113115 TEST_CHECK (ret == FLB_EVENT_DECODER_SUCCESS );
114116
117+ flb_log_event_decoder_read_groups (& log_decoder , FLB_TRUE );
118+
115119 ret = flb_log_event_decoder_next (& log_decoder , & log_event );
116120 if (ret != FLB_EVENT_DECODER_SUCCESS ) {
117121 return NULL ;
@@ -133,6 +137,8 @@ static char *get_log_body(void *chunk, size_t size)
133137 ret = flb_log_event_decoder_init (& log_decoder , chunk , size );
134138 TEST_CHECK (ret == FLB_EVENT_DECODER_SUCCESS );
135139
140+ flb_log_event_decoder_read_groups (& log_decoder , FLB_TRUE );
141+
136142 /* 0: group header */
137143 flb_log_event_decoder_next (& log_decoder , & log_event );
138144
0 commit comments