some artifacts

Author: blindspotbounty

Benchmarks/Benchmarks/SwiftKafkaConsumerBenchmarks/KafkaConsumerBenchmark.swift

@@ -23,7 +23,7 @@ import ServiceLifecycle
 
 let benchmarks = {
     var uniqueTestTopic: String!
-    let messageCount: UInt = 1000
+    let messageCount: UInt = 10_000
 
     Benchmark.defaultConfiguration = .init(
         metrics: [.wallClock, .cpuTotal, .allocatedResidentMemory, .contextSwitches, .throughput] + .arc,
@@ -211,8 +211,6 @@ let benchmarks = {
         rd_kafka_subscribe(kafkaHandle, subscriptionList)
         rd_kafka_poll(kafkaHandle, 0)
 
-        let queue = DispatchQueue(label: "com.librdkafa.consumer_poll")
-
         var ctr: UInt64 = 0
         var tmpCtr: UInt64 = 0
 
@@ -297,7 +295,7 @@ let benchmarks = {
                 guard record.pointee.err != RD_KAFKA_RESP_ERR__PARTITION_EOF else {
                     continue
                 }
-                let result = rd_kafka_commit_message(kafkaHandle, record, 0 /* sync */ )
+                let result = rd_kafka_commit_message(kafkaHandle, record, 0)
                 precondition(result == RD_KAFKA_RESP_ERR_NO_ERROR)
 
                 ctr += 1