mirror of
https://github.com/Telecominfraproject/wlan-cloud-lib-cppkafka.git
synced 2025-11-04 04:27:48 +00:00
cb2c8877d8
* Port buffer test to use Catch2 * Move compacted topic processor test to Catch2 * Move configuration tests to Catch2 * Rename configuration test cases * Move topic partition list test to Catch2 * Move handle base tests to Catch2 * Move producer tests to Catch2 * Move consumer tests to catch2 * Use CHECK on tests when appropriate * Remove googletest * Show tests' progress as they run * Update message when Catch2 is not checked out * Remove references to googletest * Run cppkafka_tests manually on travis * Print amount of time taken by each test case
45 lines
1.3 KiB
C++
45 lines
1.3 KiB
C++
#include <sstream>
|
|
#include <catch.hpp>
|
|
#include "cppkafka/topic_partition_list.h"
|
|
#include "cppkafka/topic_partition.h"
|
|
|
|
using std::ostringstream;
|
|
|
|
using namespace cppkafka;
|
|
|
|
TEST_CASE("rdkafka conversion", "[topic_partition]") {
|
|
TopicPartitionList list1;
|
|
list1.push_back("foo");
|
|
list1.push_back({ "bar", 2 });
|
|
list1.push_back({ "asd", 2, TopicPartition::OFFSET_BEGINNING });
|
|
|
|
TopicPartitionList list2 = convert(convert(list1));
|
|
|
|
CHECK(list1.size() == list2.size());
|
|
for (size_t i = 0; i < list1.size(); ++i) {
|
|
const auto& item1 = list1[i];
|
|
const auto& item2 = list2[i];
|
|
CHECK(item1.get_topic() == item2.get_topic());
|
|
CHECK(item1.get_partition() == item2.get_partition());
|
|
CHECK(item1.get_offset() == item2.get_offset());
|
|
}
|
|
}
|
|
|
|
TEST_CASE("topic partition to string", "[topic_partition]") {
|
|
ostringstream output;
|
|
TopicPartition topic_partition("foo", 5);
|
|
output << topic_partition;
|
|
CHECK(output.str() == "foo[5:#]");
|
|
}
|
|
|
|
TEST_CASE("topic partition list to string", "[topic_partition]") {
|
|
ostringstream output;
|
|
TopicPartitionList list;
|
|
list.push_back("foo");
|
|
list.push_back({ "bar", 2 });
|
|
list.push_back({ "foobar", 3, 4 });
|
|
|
|
output << list;
|
|
CHECK(output.str() == "[ foo[-1:#], bar[2:#], foobar[3:4] ]");
|
|
}
|