# Pastebin rmxELREf
(defn subscribe
  "subscribes a customer to a topic"
  [^KafkaConsumer consumer & topics]
  (.subscribe consumer (into-array topics)))