Open sixtool opened 2 years ago
I have two business kafka clusters with different groups One is to write logs One is to write business data producer:new does not support two connections to Kafka
function _M.new(self, broker_list, producer_config, cluster_name) local name = cluster_name or DEFAULT_CLUSTER_NAME
不同的集群使用 cluster_name 区分,默认是 1。
cluster_name
I have two business kafka clusters with different groups One is to write logs One is to write business data producer:new does not support two connections to Kafka