diff --git a/src/integrations/kafka/exceptions.hpp b/src/integrations/kafka/exceptions.hpp
index 6b8ab980b..390c87d18 100644
--- a/src/integrations/kafka/exceptions.hpp
+++ b/src/integrations/kafka/exceptions.hpp
@@ -11,7 +11,7 @@
 
 #pragma once
 
-#include <string>
+#include <string_view>
 
 #include "utils/exceptions.hpp"
 
@@ -22,14 +22,14 @@ class KafkaStreamException : public utils::BasicException {
 
 class ConsumerFailedToInitializeException : public KafkaStreamException {
  public:
-  ConsumerFailedToInitializeException(const std::string &consumer_name, const std::string &error)
+  ConsumerFailedToInitializeException(std::string_view consumer_name, std::string_view error)
       : KafkaStreamException("Failed to initialize Kafka consumer {} : {}", consumer_name, error) {}
 };
 
 class SettingCustomConfigFailed : public ConsumerFailedToInitializeException {
  public:
-  SettingCustomConfigFailed(const std::string &consumer_name, const std::string &error, const std::string &key,
-                            const std::string &value)
+  SettingCustomConfigFailed(std::string_view consumer_name, std::string_view error, std::string_view key,
+                            std::string_view value)
       : ConsumerFailedToInitializeException(
             consumer_name,
             fmt::format(R"(failed to set custom config ("{}": "{}"), because of error {})", key, value, error)) {}
@@ -37,31 +37,31 @@ class SettingCustomConfigFailed : public ConsumerFailedToInitializeException {
 
 class ConsumerRunningException : public KafkaStreamException {
  public:
-  explicit ConsumerRunningException(const std::string &consumer_name)
+  explicit ConsumerRunningException(std::string_view consumer_name)
       : KafkaStreamException("Kafka consumer {} is already running", consumer_name) {}
 };
 
 class ConsumerStoppedException : public KafkaStreamException {
  public:
-  explicit ConsumerStoppedException(const std::string &consumer_name)
+  explicit ConsumerStoppedException(std::string_view consumer_name)
       : KafkaStreamException("Kafka consumer {} is already stopped", consumer_name) {}
 };
 
 class ConsumerCheckFailedException : public KafkaStreamException {
  public:
-  explicit ConsumerCheckFailedException(const std::string &consumer_name, const std::string &error)
+  explicit ConsumerCheckFailedException(std::string_view consumer_name, std::string_view error)
       : KafkaStreamException("Kafka consumer {} check failed: {}", consumer_name, error) {}
 };
 
 class ConsumerStartFailedException : public KafkaStreamException {
  public:
-  explicit ConsumerStartFailedException(const std::string &consumer_name, const std::string &error)
+  explicit ConsumerStartFailedException(std::string_view consumer_name, std::string_view error)
       : KafkaStreamException("Starting Kafka consumer {} failed: {}", consumer_name, error) {}
 };
 
 class TopicNotFoundException : public KafkaStreamException {
  public:
-  TopicNotFoundException(const std::string &consumer_name, const std::string &topic_name)
+  TopicNotFoundException(std::string_view consumer_name, std::string_view topic_name)
       : KafkaStreamException("Kafka consumer {} cannot find topic {}", consumer_name, topic_name) {}
 };
 }  // namespace integrations::kafka