Skip to content

Commit 8161bd6

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 cfd42e4 commit 8161bd6

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
@@ -270,7 +270,7 @@ def retrying_send(batch)
270270
result = future.get()
271271
rescue => e
272272
# TODO(sissel): Add metric to count failures, possibly by exception type.
273-
logger.debug? && logger.debug("KafkaProducer.send() failed: #{e}", :exception => e);
273+
logger.warn("KafkaProducer.send() failed: #{e}", :exception => e)
274274
failures << batch[i]
275275
end
276276
end

0 commit comments

Comments
 (0)