private void initKafkaProducer(Properties kafkaProps, int producerNum) {
            producers = new ArrayList<>(producerNum);
            for (int i = 0; i < producerNum; i++) {
                producers.add(new KafkaProducer<>(kafkaProps));
            }
        }
take batchMsg from sendQueue and send to kafka
inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sinks/KafkaSink.java