From df8cc714536c8a4c79f8ed3339729db611c2f9f6 Mon Sep 17 00:00:00 2001 From: Silviu Caragea Date: Thu, 28 Mar 2019 11:01:29 +0200 Subject: [PATCH] Revert sys.config for benchmark testing --- test/sys.config | 37 ++++++++++++++++++++++++++++++++++--- 1 file changed, 34 insertions(+), 3 deletions(-) diff --git a/test/sys.config b/test/sys.config index 1c52df7..2571b2e 100644 --- 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"} + ]} + ]} ]} ]} ].