Emit debug, not error from Elasticsearch sink (#423)

We have a number of error notifs in the ES sink that are not
really errors. This is now corrected by flipping these things
to debug.

Signed-off-by: Brian L. Troutwine <blt@postmates.com>

src/sink/elasticsearch.rs

@@ -228,13 +228,13 @@ impl Sink<ElasticsearchConfig> for Elasticsearch {
                                 ELASTIC_RECORDS_TOTAL_FAILED
                                     .fetch_add(1, Ordering::Relaxed);
                                 if let Some(cause) = item.cause() {
-                                    error!(
+                                    debug!(
                                         "Failed to write item with error {}, cause {}",
                                         item.description(),
                                         cause
                                     );
                                 } else {
-                                    error!(
+                                    debug!(
                                         "Failed to write item with error {}",
                                         item.description()
                                     );
@@ -268,23 +268,23 @@ impl Sink<ElasticsearchConfig> for Elasticsearch {
                             ApiError::IndexNotFound { ref index } => {
                                 ELASTIC_ERROR_API_INDEX_NOT_FOUND
                                     .fetch_add(1, Ordering::Relaxed);
-                                error!(
+                                debug!(
                                     "Unable to write, API Error (Index Not Found): {}",
                                     index
                                 );
                             }
                             ApiError::Parsing { ref reason, .. } => {
                                 ELASTIC_ERROR_API_PARSING
                                     .fetch_add(1, Ordering::Relaxed);
-                                error!(
+                                debug!(
                                     "Unable to write, API Error (Parsing): {}",
                                     reason
                                 );
                             }
                             ApiError::MapperParsing { ref reason, .. } => {
                                 ELASTIC_ERROR_API_MAPPER_PARSING
                                     .fetch_add(1, Ordering::Relaxed);
-                                error!(
+                                debug!(
                                     "Unable to write, API Error (Mapper Parsing): {}",
                                     reason
                                 );
@@ -294,37 +294,37 @@ impl Sink<ElasticsearchConfig> for Elasticsearch {
                             } => {
                                 ELASTIC_ERROR_API_ACTION_REQUEST_VALIDATION
                                     .fetch_add(1, Ordering::Relaxed);
-                                error!(
+                                debug!(
                                     "Unable to write, API Error (Action Request Validation): {}",
                                     reason
                                 );
                             }
                             ApiError::DocumentMissing { ref index, .. } => {
                                 ELASTIC_ERROR_API_DOCUMENT_MISSING
                                     .fetch_add(1, Ordering::Relaxed);
-                                error!(
+                                debug!(
                                 "Unable to write, API Error (Document Missing): {}",
                                 index
                             );
                             }
                             ApiError::IndexAlreadyExists { ref index, .. } => {
                                 ELASTIC_ERROR_API_INDEX_ALREADY_EXISTS
                                     .fetch_add(1, Ordering::Relaxed);
-                                error!(
+                                debug!(
                                     "Unable to write, API Error (Index Already Exists): {}",
                                     index
                                 );
                             }
                             _ => {
                                 ELASTIC_ERROR_API_UNKNOWN
                                     .fetch_add(1, Ordering::Relaxed);
-                                error!("Unable to write, API Error (Unknown)");
+                                debug!("Unable to write, API Error (Unknown)");
                             }
                         }
                     }
                     error::Error::Client(ref client_error) => {
                         ELASTIC_ERROR_CLIENT.fetch_add(1, Ordering::Relaxed);
-                        error!(
+                        debug!(
                             "Unable to write, client error: {}",
                             client_error.description()
                         );