Revert sys.config for benchmark testing

silviucpp · Mar 28, 2019 · df8cc71 · df8cc71
1 parent 8b0a847
commit df8cc71
Showing 1 changed file with 34 additions and 3 deletions.
diff --git a/test/sys.config b/test/sys.config
@@ -28,9 +28,40 @@
     ]},
 
     {erlkaf, [
-        {global_client_options, [
-            {bootstrap_servers, <<"172.17.3.163:9092,172.17.3.164:9092,172.17.3.165:9092">>},
-            {socket_keepalive_enable, true}
+        {clients, [
+            {client_producer,[
+
+                {type, producer},
+
+                {topics, [
+                    {<<"benchmark">>, [{request_required_acks, 0}]}
+                ]},
+
+                {client_options, [
+                    {bootstrap_servers, "172.17.3.163:9092,172.17.3.164:9092,172.17.3.165:9092"},
+                    {delivery_report_only_error, true},
+                    {delivery_report_callback, benchmark_producer},
+                    {queue_buffering_max_messages, 1000000}
+                ]}
+            ]},
+
+            {client_consumer,[
+
+                {type, consumer},
+
+                {group_id, <<"erlkaf_consumer">>},
+                {callback_module, test_consumer},
+                {callback_args, []},
+                {topics, [<<"benchmark">>]},
+                {topic_options, [
+                    {auto_offset_reset, smallest},
+                    {dispatch_mode, one_by_one}
+                ]},
+
+                {client_options, [
+                    {bootstrap_servers, "172.17.3.163:9092"}
+                ]}
+            ]}
         ]}
     ]}
 ].