diff --git a/include/cppkafka/CMakeLists.txt b/include/cppkafka/CMakeLists.txt
index 2f8f6f2..f4c188e 100644
--- a/include/cppkafka/CMakeLists.txt
+++ b/include/cppkafka/CMakeLists.txt
@@ -1,6 +1,12 @@
 file(GLOB INCLUDE_FILES "*.h")
+file(GLOB UTILS_INCLUDE_FILES "utils/*.h")
 install(
-    FILES ${INCLUDE_FILES} 
+    FILES ${INCLUDE_FILES}
     DESTINATION include/cppkafka
     COMPONENT Headers
 )
+install(
+    FILES ${UTILS_INCLUDE_FILES}
+    DESTINATION include/cppkafka/utils/
+    COMPONENT Headers
+)
\ No newline at end of file
diff --git a/include/cppkafka/compacted_topic_processor.h b/include/cppkafka/utils/compacted_topic_processor.h
similarity index 99%
rename from include/cppkafka/compacted_topic_processor.h
rename to include/cppkafka/utils/compacted_topic_processor.h
index d94e90b..8d8f475 100644
--- a/include/cppkafka/compacted_topic_processor.h
+++ b/include/cppkafka/utils/compacted_topic_processor.h
@@ -39,7 +39,7 @@
 #include "consumer.h"
 
 namespace cppkafka {
-
+namespace utils {
 /**
  * \brief Events generated by a CompactedTopicProcessor
  */
@@ -341,6 +341,7 @@ void CompactedTopicProcessor<K, V>::on_assignment(TopicPartitionList& topic_part
     }
 }
 
+} // utils
 } // cppkafka
 
 #endif // CPPKAFKA_COMPACTED_TOPIC_PROCESSOR_H