lib/fluent/plugin/out_kafka2.rb in fluent-plugin-kafka-0.17.2 vs lib/fluent/plugin/out_kafka2.rb in fluent-plugin-kafka-0.17.3
- old
+ new
@@ -266,10 +266,11 @@
end
record_buf = @formatter_proc.call(tag, time, record)
record_buf_bytes = record_buf.bytesize
if @max_send_limit_bytes && record_buf_bytes > @max_send_limit_bytes
- log.warn "record size exceeds max_send_limit_bytes. Skip event:", :time => time, :record => record
+ log.warn "record size exceeds max_send_limit_bytes. Skip event:", :time => time, :record_size => record_buf_bytes
+ log.debug "Skipped event:", :record => record
next
end
rescue StandardError => e
log.warn "unexpected error during format record. Skip broken event:", :error => e.to_s, :error_class => e.class.to_s, :time => time, :record => record
next