diff --git a/lib/kafka/produce_operation.rb b/lib/kafka/produce_operation.rb index 766fa568..d327fb7d 100644 --- a/lib/kafka/produce_operation.rb +++ b/lib/kafka/produce_operation.rb @@ -104,7 +104,7 @@ def send_buffered_messages messages_for_broker.each do |broker, message_buffer| begin - @logger.info "Sending #{message_buffer.size} messages to #{broker}" + @logger.debug "Sending #{message_buffer.size} messages to #{broker}" records_for_topics = {}