func ConcurrencyHandler(sms models.Message) {
	var (
		cfg      = config.New()
		producer = kafka.CreateKafkaProducer(cfg)
	)

	kafka.ProduceMessage(cfg, producer, sms, "")

	producer.Close()
}
// ConcurrencyHandler handles the process of passing data to Kafka in parallel
ConcurrencyHandler handles the process of passing data to Kafka in parallel
// ConcurrencyHandler handles the process of passing data to Kafka in parallel
func ConcurrencyHandler(sms models.Message) {
	var (
		cfg      = config.New()
		producer = kafka.CreateKafkaProducer(cfg)
	)
	kafka.ProduceMessage(cfg, producer, sms, "")
	producer.Close()
}
func ConcurrencyHandler ( sms models . Message ) { var ( cfg = config . New ( ) producer = kafka . CreateKafkaProducer ( cfg ) ) kafka . ProduceMessage ( cfg , producer , sms , " " ) producer . Close ( ) }
ConcurrencyHandler handles the process of passing data to Kafka in parallel
ConcurrencyHandler handles the process of passing data to Kafka in parallel