@@ -657,6 +657,42 @@ static void flb_test_forward_group_size_default()
657657 NULL , NULL );
658658 TEST_CHECK (ret == 0 );
659659
660+ run_group_count_test (ctx );
661+ TEST_CHECK (get_forward_size () == 3 );
662+
663+ flb_destroy (ctx );
664+ }
665+
666+ static void flb_test_forward_group_size_opt_out_metadata ()
667+ {
668+ int out_ffd ;
669+ int in_ffd ;
670+ int ret ;
671+ flb_ctx_t * ctx ;
672+
673+ reset_results ();
674+
675+ ctx = flb_create ();
676+ flb_service_set (ctx , "Flush" , "0.2" , "Grace" , "1" , "Log_Level" , "error" , NULL );
677+
678+ in_ffd = flb_input (ctx , (char * ) "lib" , NULL );
679+ TEST_CHECK (in_ffd >= 0 );
680+ flb_input_set (ctx , in_ffd , "tag" , "test" , NULL );
681+
682+ out_ffd = flb_output (ctx , (char * ) "forward" , NULL );
683+ TEST_CHECK (out_ffd >= 0 );
684+ flb_output_set (ctx , out_ffd ,
685+ "match" , "test" ,
686+ "tag" , "new.tag" ,
687+ "send_options" , "true" ,
688+ "retain_metadata_in_forward_mode" , "false" ,
689+ NULL );
690+
691+ ret = flb_output_set_test (ctx , out_ffd , "formatter" ,
692+ cb_forward_size_check ,
693+ NULL , NULL );
694+ TEST_CHECK (ret == 0 );
695+
660696 run_group_count_test (ctx );
661697 TEST_CHECK (get_forward_size () == 1 );
662698
@@ -873,6 +909,7 @@ static void flb_test_forward_output_processor_mixed_payload_smoke()
873909
874910TEST_LIST = {
875911 {"forward_group_size_default" , flb_test_forward_group_size_default },
912+ {"forward_group_size_opt_out_metadata" , flb_test_forward_group_size_opt_out_metadata },
876913 {"forward_group_size_retain_metadata" , flb_test_forward_group_size_retain_metadata },
877914 {"forward_group_size_retain_metadata_upstream_node" ,
878915 flb_test_forward_group_size_retain_metadata_upstream_node },
0 commit comments