From 8ae5e9d573fe6fa7bb6229203c7e08735031276c Mon Sep 17 00:00:00 2001
From: accelerated <>
Date: Wed, 6 Feb 2019 18:06:32 -0500
Subject: [PATCH] Fixed buffer test array initialization warning for clang

---
 tests/buffer_test.cpp          | 2 +-
 tests/roundrobin_poll_test.cpp | 7 ++++---
 2 files changed, 5 insertions(+), 4 deletions(-)

diff --git a/tests/buffer_test.cpp b/tests/buffer_test.cpp
index c4c9210..9aa55cd 100644
--- a/tests/buffer_test.cpp
+++ b/tests/buffer_test.cpp
@@ -43,7 +43,7 @@ TEST_CASE("construction", "[buffer]") {
     // From vector
     const vector<uint8_t> vector_data(str_data.begin(), str_data.end());
     // From array
-    const array<char,12> array_data{'H','e','l','l','o',' ','w','o','r','l','d','!'};
+    const array<char,12> array_data{{'H','e','l','l','o',' ','w','o','r','l','d','!'}};
     // From raw array
     const char raw_array[12]{'H','e','l','l','o',' ','w','o','r','l','d','!'};
     
diff --git a/tests/roundrobin_poll_test.cpp b/tests/roundrobin_poll_test.cpp
index a1719f8..f3aaa87 100644
--- a/tests/roundrobin_poll_test.cpp
+++ b/tests/roundrobin_poll_test.cpp
@@ -36,6 +36,7 @@ using namespace cppkafka;
 static Configuration make_producer_config() {
     Configuration config = {    
         { "metadata.broker.list", KAFKA_TEST_INSTANCE },
+        { "max.in.flight", 1 }
     };
     return config;
 }
@@ -82,7 +83,7 @@ TEST_CASE("roundrobin consumer test", "[roundrobin consumer]") {
     
     // push 3 messages in each partition
     for (int i = 0; i < total_messages; ++i) {
-        producer.produce(MessageBuilder(KAFKA_TOPICS[0])
+        producer.sync_produce(MessageBuilder(KAFKA_TOPICS[0])
                             .partition(i % KAFKA_NUM_PARTITIONS)
                             .payload(payload));
     }
@@ -101,7 +102,7 @@ TEST_CASE("roundrobin consumer test", "[roundrobin consumer]") {
             // find first polled partition index
             partition_idx = runner.get_messages()[i].get_partition();
         }
-        REQUIRE(runner.get_messages()[i].get_partition() == partition_order[i+partition_idx]);
+        CHECK(runner.get_messages()[i].get_partition() == partition_order[i+partition_idx]);
         REQUIRE((string)runner.get_messages()[i].get_payload() == payload);
     }
     
@@ -115,7 +116,7 @@ TEST_CASE("roundrobin consumer test", "[roundrobin consumer]") {
     payload = "SerialPolling";
     // push 3 messages in each partition
     for (int i = 0; i < total_messages; ++i) {
-        producer.produce(MessageBuilder(KAFKA_TOPICS[0]).partition(i%KAFKA_NUM_PARTITIONS).payload(payload));
+        producer.sync_produce(MessageBuilder(KAFKA_TOPICS[0]).partition(i%KAFKA_NUM_PARTITIONS).payload(payload));
     }
     producer.flush();
     serial_runner.try_join();