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