test/appender/kafka_test.rb in semantic_logger-4.2.0 vs test/appender/kafka_test.rb in semantic_logger-4.2.1
- old
+ new
@@ -3,34 +3,33 @@
module Appender
class KafkaTest < Minitest::Test
describe SemanticLogger::Appender::Kafka do
before do
@appender = SemanticLogger::Appender::Kafka.new(
- seed_brokers: ['http://localhost:9092']
+ seed_brokers: ['localhost:9092']
)
@message = 'AppenderKafkaTest log message'
end
after do
- @appender.close if @appender
+ @appender&.close
end
it 'sends log messages in JSON format' do
message = nil
options = nil
- ::Kafka::Producer.stub_any_instance(:produce, -> value, **opts { message = value; options = opts }) do
+ ::Kafka::Producer.stub_any_instance(:produce, ->(value, **opts) { message = value; options = opts }) do
@appender.info(@message)
@appender.flush
end
h = JSON.parse(message)
assert_equal 'info', h['level']
assert_equal @message, h['message']
- assert_equal "SemanticLogger::Appender::Kafka", h['name']
- assert_equal $$, h['pid']
+ assert_equal 'SemanticLogger::Appender::Kafka', h['name']
+ assert_equal $PROCESS_ID, h['pid']
assert_equal 'log_messages', options[:topic]
end
-
end
end
end