chore(cljfmt) format buffers

Author: iomonad

project.clj

@@ -21,4 +21,4 @@
                                   [org.clojure/core.async "0.5.527"]
                                   [spootnik/unilog        "0.7.30"]]
                    :source-paths ["dev"]}}
-   :repl-options {:init-ns user})
+  :repl-options {:init-ns user})

src/felice/admin.clj

@@ -28,7 +28,6 @@
   {:metadata (.metadata offset-metadata)
    :offset (.offset offset-metadata)})
 
-
 (defn admin-client
   "Instanciate an `Admin` from properties"
   {:added "3.2.0-1.7"}
@@ -38,7 +37,6 @@
                     (dissoc :key.deserializer :value.deserializer :topics))]
      (Admin/create ^java.util.Map props*))))
 
-
 (defn admin-close
   "Close the Admin client and release all associated resources.
 
@@ -52,7 +50,6 @@
   ([^Admin ac]
    (.close ac)))
 
-
 (defn admin-metrics
   "Get the metrics kept by the adminClient"
   {:added "3.2.0-1.7"}
@@ -67,7 +64,6 @@
                       :tags (.tags name)
                       :value (.metricValue o)}))))))
 
-
 (defn describe-cluster
   "Get information about the nodes in the cluster,
    using the default options."
@@ -81,7 +77,6 @@
       :controller-node (->node (deref (.controller desc)))
       :nodes (map ->node (deref (.nodes desc)))})))
 
-
 (defn list-topics
   "List topics for the current `Admin` connection"
   {:added "3.2.0-1.7"}
@@ -90,7 +85,6 @@
             (.names)
             deref)))
 
-
 (defn- safely-resolve-field [class f]
   (try (.get (.getField class f) nil) (catch Exception _ nil)))
 (defn- static-field->props
@@ -109,7 +103,6 @@
    (sorted-map)
    m))
 
-
 (defn- mk-topic-instance
   ^NewTopic
   [^String topic-name partition-count replication-factor props]
@@ -188,14 +181,12 @@
                       :status :kafka.topic/error})))))
      (throw (ex-info "Bad Topics spec" (s/explain-data (s/coll-of :kafka.topic/name) topics))))))
 
-
 (defn delete-topic
   "Delete a topic"
   {:added "3.2.0-1.7"}
   ([^Admin ac topic-name]
    (first (delete-topics ac #{topic-name}))))
 
-
 (defn describe-topics
   "Describe some topics in the cluster.
 
@@ -214,14 +205,12 @@
                             :partitions (map ->topic-partition (.partitions o))}))
                   (sorted-map))))))
 
-
 (defn describe-topic
   "Describe a topic."
   {:added "3.2.0-1.7"}
   ([^Admin ac topic]
    (first (describe-topic ac #{topic}))))
 
-
 (defn list-consumer-groups
   "List the consumer groups for the current `Admin`
    connection"
@@ -235,7 +224,6 @@
                     :is-simple-consumer-group (.isSimpleConsumerGroup o)
                     :state (keyword (.orElse (.state o) "unknown"))})))))
 
-
 (defn list-consumer-groups-offsets
   "List consumer group offsets, if no group id specified,
    compute for all the group-id well-known in the current
@@ -263,7 +251,6 @@
                                 [t (map #(dissoc % :topic-name) v)])
                               per-topic-offsets))}))))
 
-
 (defn sum-consumer-groups-offsets
   "Sum consumer group offset over all partitions"
   {:added "3.2.0-1.7"}
@@ -280,7 +267,6 @@
                               :sum (apply + (map #(get-in % [:metadata :offset])
                                                  offsets))})))}))))
 
-
 (defn set-consumer-group-topic-offset
   "Alters offsets for the specified group of a specific topic.
 
@@ -310,7 +296,6 @@
                               second)}
            (recur op)))))))
 
-
 (defn delete-consumer-groups
   "Delete consumer groups from the cluster with the default options."
   {:added "3.2.0-1.7"}
@@ -327,7 +312,6 @@
                     :status :kafka.consumer-group/error
                     :message (.getMessage e)})))))))
 
-
 (defn delete-consumer-group
   "Delete one consumer group from the cluster
    with the default options."

src/felice/consumer.clj

@@ -69,7 +69,7 @@
 
 (defn metrics
   "returns a list of mtrics mapkept by the consumer"
-    {:added "3.2.0-1.7"}
+  {:added "3.2.0-1.7"}
   [^KafkaConsumer consumer]
   (map (fn [^java.util.Map$Entry m] (metric->map (.getValue m))) (.metrics consumer)))
 

test/felice/admin_test.clj

@@ -36,7 +36,6 @@
       (is (= #{:cluster-id :authorized-operation :controller-node :nodes} (set (keys (admin/describe-cluster admin-client)))))
       (admin/admin-close admin-client))))
 
-
 (deftest consumer-state-tests
   (testing "consumer state tests"
     (let [group-id "test-1"
@@ -75,7 +74,7 @@
 
       ;;Reset all the offset to beginning
       (is (= [0]
-             (map #(get-in %[:metadata :offset]) (:offsets (admin/set-consumer-group-topic-offset admin-client group-id topic 0)))))
+             (map #(get-in % [:metadata :offset]) (:offsets (admin/set-consumer-group-topic-offset admin-client group-id topic 0)))))
 
       (def consumer-2 (consumer/consumer {:bootstrap.servers "localhost:9092"
                                           :group.id group-id
@@ -84,9 +83,7 @@
 
       (consumer/subscribe consumer-2 topic)
 
-
-
-      ;; Let's replay test then
+;; Let's replay test then
       (let [consumer-records (consumer/poll consumer-2 100000)
             records (consumer/poll->all-records consumer-records)]
         (is (not (.isEmpty consumer-records)) "we have polled something")

test/felice/core_test.clj

@@ -13,7 +13,6 @@
 (ul/start-logging! (-> ul/default-configuration
                        (assoc :overrides {"org.apache" :warn})))
 
-
 (deftest client
   (testing "produce and consume strings"
     (let [admin-client (admin/admin-client {:bootstrap.servers "localhost:9092"})