improve error messages

Author: fbs

src/sources/opentelemetry/config.rs

@@ -230,7 +230,7 @@ impl SourceConfig for OpentelemetryConfig {
             cx.shutdown.clone(),
         )
         .map_err(|error| {
-            error!(message = "Source future failed.", %error);
+            error!(message = "OpenTelemetry gRPC source failed. Terminating.", %error);
         });
 
         let http_tls_settings = MaybeTlsSettings::from_config(self.http.tls.as_ref(), true)?;
@@ -259,7 +259,7 @@ impl SourceConfig for OpentelemetryConfig {
             self.http.keepalive.clone(),
         )
         .map_err(|error| {
-            error!(message = "Source future failed.", %error);
+            error!(message = "OpenTelemetry HTTP source failed. Terminating", %error);
         });
 
         Ok(join(grpc_source, http_source).map(|_| Ok(())).boxed())