File tree Expand file tree Collapse file tree 2 files changed +3
-3
lines changed Expand file tree Collapse file tree 2 files changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -55,7 +55,7 @@ class ForwardInput < Input
55
55
desc 'Received chunk is dropped if it is larger than this value.'
56
56
config_param :chunk_size_limit , :size , default : nil
57
57
desc 'Skip an event if incoming event is invalid.'
58
- config_param :skip_invalid_event , :bool , default : false
58
+ config_param :skip_invalid_event , :bool , default : true
59
59
60
60
desc "The field name of the client's source address."
61
61
config_param :source_address_key , :string , default : nil
Original file line number Diff line number Diff line change @@ -541,7 +541,7 @@ def try_write(chunk)
541
541
end
542
542
543
543
test 'send_compressed_message_pack_stream_if_compress_is_gzip' do
544
- target_input_driver = create_target_input_driver
544
+ target_input_driver = create_target_input_driver ( conf : target_config + "skip_invalid_event false" )
545
545
546
546
@d = d = create_driver ( config + %[
547
547
flush_interval 1s
@@ -571,7 +571,7 @@ def try_write(chunk)
571
571
end
572
572
573
573
test 'send_compressed_message_pack_stream_if_compress_is_zstd' do
574
- target_input_driver = create_target_input_driver
574
+ target_input_driver = create_target_input_driver ( conf : target_config + "skip_invalid_event false" )
575
575
576
576
@d = d = create_driver ( config + %[
577
577
flush_interval 1s
You can’t perform that action at this time.
0 commit comments