scottk/wlan-cloud-lib-cppkafka
1
0
Fork 0
mirror of https://github.com/Telecominfraproject/wlan-cloud-lib-cppkafka.git synced 2025-11-01 11:07:56 +00:00
Code Issues Packages Projects Releases Wiki Activity

Make producer test work on librdkafka v0.9.4

Browse Source
This commit is contained in:
Matias Fontanini
2017-04-15 18:13:56 -07:00
parent c99c8bbb05
commit 91cd9a2957
1 changed files with 12 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

21
tests/producer_test.cpp
View File

@@ -88,16 +88,19 @@ public:
static const string KAFKA_TOPIC; static const string KAFKA_TOPIC;
Configuration make_producer_config() { Configuration make_producer_config() {
Configuration config; Configuration config = {
config.set("metadata.broker.list", KAFKA_TEST_INSTANCE); { "metadata.broker.list", KAFKA_TEST_INSTANCE },
{ "queue.buffering.max.ms", 0 }
};
return config; return config;
} }
Configuration make_consumer_config() { Configuration make_consumer_config() {
Configuration config; Configuration config = {
config.set("metadata.broker.list", KAFKA_TEST_INSTANCE); { "metadata.broker.list", KAFKA_TEST_INSTANCE },
config.set("enable.auto.commit", false); { "enable.auto.commit", false },
config.set("group.id", "producer_test"); { "group.id", "producer_test" }
};
return config; return config;
} }
}; };
@@ -206,11 +209,11 @@ TEST_F(ProducerTest, Callbacks) {
// Now create a producer and produce a message // Now create a producer and produce a message
string payload = "Hello world! 3"; string payload = "Hello world! 3";
string key = "hehe"; string key = "hehe";
bool deliver_report_called = false; bool delivery_report_called = false;
Configuration config = make_producer_config(); Configuration config = make_producer_config();
config.set_delivery_report_callback([&](Producer&, const Message& msg) { config.set_delivery_report_callback([&](Producer&, const Message& msg) {
EXPECT_EQ(Buffer(payload), msg.get_payload()); EXPECT_EQ(Buffer(payload), msg.get_payload());
deliver_report_called = true; delivery_report_called = true;
}); });
TopicConfiguration topic_config; TopicConfiguration topic_config;
@@ -236,7 +239,7 @@ TEST_F(ProducerTest, Callbacks) {
EXPECT_EQ(KAFKA_TOPIC, message.get_topic()); EXPECT_EQ(KAFKA_TOPIC, message.get_topic());
EXPECT_EQ(partition, message.get_partition()); EXPECT_EQ(partition, message.get_partition());
EXPECT_FALSE(message.get_error()); EXPECT_FALSE(message.get_error());
EXPECT_TRUE(deliver_report_called); EXPECT_TRUE(delivery_report_called);
} }
TEST_F(ProducerTest, PartitionerCallbackOnDefaultTopicConfig) { TEST_F(ProducerTest, PartitionerCallbackOnDefaultTopicConfig) {