Skip to content

Commit 6d3dd87

Browse files
committed
Log Kafka send errors as warn
Log errors encountered when sending messages to Kafka at warn, rather than debug, to improve the visibility of errors such as 'RecordTooLargeException.' Fixes #177 Fixes #179
1 parent d06346e commit 6d3dd87

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

lib/logstash/outputs/kafka.rb

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -275,7 +275,7 @@ def retrying_send(batch)
275275
result = future.get()
276276
rescue => e
277277
# TODO(sissel): Add metric to count failures, possibly by exception type.
278-
logger.debug? && logger.debug("KafkaProducer.send() failed: #{e}", :exception => e);
278+
logger.warn("KafkaProducer.send() failed: #{e}", :exception => e)
279279
failures << batch[i]
280280
end
281281
end

0 commit comments

Comments
 (0)