diff --git a/cpp/libcudf_kafka/include/cudf_kafka/kafka_consumer.hpp b/cpp/libcudf_kafka/include/cudf_kafka/kafka_consumer.hpp index 97276447bf3..b9b4b59347e 100644 --- a/cpp/libcudf_kafka/include/cudf_kafka/kafka_consumer.hpp +++ b/cpp/libcudf_kafka/include/cudf_kafka/kafka_consumer.hpp @@ -25,7 +25,7 @@ namespace cudf { namespace io { -namespace datasource { +namespace external { namespace kafka { /** @@ -115,6 +115,6 @@ class kafka_consumer : public cudf::io::datasource { }; } // namespace kafka -} // namespace datasource +} // namespace external } // namespace io } // namespace cudf diff --git a/cpp/libcudf_kafka/src/kafka_consumer.cpp b/cpp/libcudf_kafka/src/kafka_consumer.cpp index c68b8143775..39985c73a6e 100644 --- a/cpp/libcudf_kafka/src/kafka_consumer.cpp +++ b/cpp/libcudf_kafka/src/kafka_consumer.cpp @@ -21,7 +21,7 @@ namespace cudf { namespace io { -namespace datasource { +namespace external { namespace kafka { kafka_consumer::kafka_consumer(std::map configs, @@ -109,6 +109,6 @@ void kafka_consumer::consume_to_buffer() } } // namespace kafka -} // namespace datasource +} // namespace external } // namespace io } // namespace cudf