class Promenade::Kafka::Subscriber

Private Instance Methods

get_labels(event) click to toggle source
# File lib/promenade/kafka/subscriber.rb, line 9
def get_labels(event)
  client = event.payload.fetch(:client_id)
  topic = event.payload.fetch(:topic)
  { client: client, topic: topic }
end