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