diff --git a/include/cppkafka/metadata.h b/include/cppkafka/metadata.h index a705aa2..fdea17b 100644 --- a/include/cppkafka/metadata.h +++ b/include/cppkafka/metadata.h @@ -91,7 +91,7 @@ public: /** * Gets the topic name */ - const std::string& get_topic() const; + const std::string& get_name() const; /** * Gets the topic error @@ -103,7 +103,7 @@ public: */ const std::vector& get_partitions() const; private: - std::string topic_; + std::string name_; rd_kafka_resp_err_t error_; std::vector partitions_; }; diff --git a/src/metadata.cpp b/src/metadata.cpp index c6dd12c..93e9260 100644 --- a/src/metadata.cpp +++ b/src/metadata.cpp @@ -71,14 +71,14 @@ const vector& PartitionMetadata::get_in_sync_replica_brokers() const { // TopicMetadata TopicMetadata::TopicMetadata(const rd_kafka_metadata_topic& topic) -: topic_(topic.topic), error_(topic.err) { +: name_(topic.topic), error_(topic.err) { for (int i = 0; i < topic.partition_cnt; ++i) { partitions_.emplace_back(topic.partitions[i]); } } -const string& TopicMetadata::get_topic() const { - return topic_; +const string& TopicMetadata::get_name() const { + return name_; } Error TopicMetadata::get_error() const { diff --git a/tests/kafka_handle_base_test.cpp b/tests/kafka_handle_base_test.cpp index 69c9cea..7f82092 100644 --- a/tests/kafka_handle_base_test.cpp +++ b/tests/kafka_handle_base_test.cpp @@ -70,7 +70,7 @@ TEST_F(KafkaHandleBaseTest, TopicsMetadata) { ASSERT_GE(topics.size(), 2); for (const auto& topic : topics) { - if (topic_names.count(topic.get_topic()) == 1) { + if (topic_names.count(topic.get_name()) == 1) { const vector& partitions = topic.get_partitions(); EXPECT_EQ(3, partitions.size()); set expected_ids = { 0, 1, 2 }; @@ -95,5 +95,5 @@ TEST_F(KafkaHandleBaseTest, TopicsMetadata) { // Now get the whole metadata only for this topic Topic topic = producer.get_topic(KAFKA_TOPIC); - EXPECT_EQ(KAFKA_TOPIC, producer.get_metadata(topic).get_topic()); + EXPECT_EQ(KAFKA_TOPIC, producer.get_metadata(topic).get_name()); }