From cf6dc03eec576309ab7aa1c86641a5aa09d43e18 Mon Sep 17 00:00:00 2001
From: Matias Fontanini <matias.fontanini@gmail.com>
Date: Fri, 28 Oct 2016 07:24:26 -0700
Subject: [PATCH] Move compacted topic processor into utils directory

---
 include/cppkafka/CMakeLists.txt                          | 8 +++++++-
 include/cppkafka/{ => utils}/compacted_topic_processor.h | 3 ++-
 2 files changed, 9 insertions(+), 2 deletions(-)
 rename include/cppkafka/{ => utils}/compacted_topic_processor.h (99%)

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