Evidence Log to acknowledge one (not all) Kafka replica(s).

This is more robust in the case of partial cluster Kafka failure.
Also demote 'error' to 'info' for URL tracking params stripping.

Author: Joe Wass

project.clj

@@ -1,4 +1,4 @@
-(defproject event-data-common "0.1.59"
+(defproject event-data-common "0.1.60"
   :description "Crossref Event Data Common"
   :url "http://eventdata.crossref.org"
   :license {:name "The MIT License (MIT)"

src/event_data_common/evidence_log.clj

@@ -15,7 +15,9 @@
   (delay
     (KafkaProducer. {
       "bootstrap.servers" (:global-kafka-bootstrap-servers env)
-      "acks" "all"
+      ; Make sure it's flushed on the broker, but don't wait for all replicas.
+      ; This is more robust if one replica stops working.
+      "acks" "1"
       "retries" (int 5)
       "key.serializer" "org.apache.kafka.common.serialization.StringSerializer"
       "value.serializer" "org.apache.kafka.common.serialization.StringSerializer"})))

src/event_data_common/url_cleanup.clj

@@ -49,7 +49,9 @@
                       (.build))]
       (str new-uri))
 
+    ; This can happen because the URL isn't a vailid URI, e.g. illegal chars in fragment.
+    ; No big deal, this is best-effort. 
     (catch Exception ex
       (do
-        (log/error "Failed to remove tracking params" url)
+        (log/info "Failed to remove tracking params" url)
         url))))