class CrossSpec::KafkaClient
Constants
- TOPIC
Public Class Methods
new(kafka)
click to toggle source
# File lib/cross_spec/kafka_client.rb, line 4 def initialize(kafka) @kafka = kafka end
Public Instance Methods
broadcast(str)
click to toggle source
# File lib/cross_spec/kafka_client.rb, line 8 def broadcast(str) @kafka.deliver_message(str, topic: TOPIC) end
each_message(&block)
click to toggle source
# File lib/cross_spec/kafka_client.rb, line 12 def each_message(&block) consumer = @kafka.consumer(group_id: group_id) consumer.subscribe(TOPIC) consumer.each_message(&block) end
group_id()
click to toggle source
# File lib/cross_spec/kafka_client.rb, line 18 def group_id @group_id ||= "cross-spec-#{SecureRandom.hex}" end