lua-resty-kafka
lua-resty-kafka copied to clipboard
broker_list parameter didn't take effect when add producer_type = "async" to producer constructor
I have multi route in nginx config, each route register a kafka topic to produce message into each kafka cluster. The problem I have come across is that when I add a new route to send one topic into a new kafka cluster with the producer_type = "async"
parameter, I saw the new topic messages still send into the kafka cluster I have configiured in the old route. I solve this problem by removing the producer_type = "async"
parameter.
May this will help.
there is a config 'cluster_name'