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