erlkaf

[
    {lager, [
        {handlers, [
            {lager_console_backend, [
                {level, info}
            ]}
        ]}
    ]},

    {brod, [
        {clients, [
            {kafka_client, [
                {endpoints, [
                    {"172.17.33.123", 9092},
                    {"172.17.33.124", 9092},
                    {"172.17.33.125", 9092}
                ]},

                {auto_start_producers, true},
                {reconnect_cool_down_seconds, 5},
                {default_producer_config, [{required_acks, 0}]}
            ]}
        ]}
    ]},

    {erlkaf, [
        {global_client_options, [
            {bootstrap_servers, <<"172.17.33.123:9092,172.17.33.124:9092,172.17.33.125:9092">>},
            {socket_keepalive_enable, true},
            {queue_buffering_overflow_strategy, local_disk_queue}
        ]},

        {clients, [
            {client_producer,[

                {type, producer},

                {topics, [
                    {<<"benchmark">>, [{request_required_acks, 0}]}
                ]},

                {client_options, [
                    {delivery_report_only_error, true},
                    {delivery_report_callback, benchmark_producer},
                    {queue_buffering_max_messages, 1000000}
                ]}
            ]},

            {client_consumer, [

                {type, consumer},

                {group_id, <<"erlkaf_consumer">>},
                {topics, [
                    {<<"benchmark">>, [
                        {callback_module, test_consumer},
                        {callback_args, []},
                        {dispatch_mode, one_by_one}
                    ]}
                ]},

                {topic_options, [
                    {auto_offset_reset, smallest}
                ]},

                {client_options, []}
            ]}
        ]}
    ]}
].