func MustSetupProducer(brokers string) Producer {
	defaultSerializer := func(msg ProducerMessage) ([]byte, error) {
		return json.Marshal(msg)
	}

	return MustSetupProducerWithSerializer(brokers, defaultSerializer)
}
// mustSetupProducer creates a producer for the kafka queues on brokers
// brokers is a comma separated list of kafka nodes with host and ip, eg "172.0.0.1:9092,172.0.0.2:9092"
mustSetupProducer creates a producer for the kafka queues on brokers
brokers is a comma separated list of kafka nodes with host and ip, eg "172.0.0.1:9092,172.0.0.2:9092"
// mustSetupProducer creates a producer for the kafka queues on brokers // brokers is a comma separated list of kafka nodes with host and ip eg " 172 . 0 . 0 . 1 : 9092 172 . 0 . 0 . 2 : 9092 "
func MustSetupProducer(brokers string) Producer {
	defaultSerializer := func(msg ProducerMessage) ([]byte, error) {
		return json.Marshal(msg)
	}
	return MustSetupProducerWithSerializer(brokers, defaultSerializer)
}
func MustSetupProducer ( brokers string ) Producer { defaultSerializer := func ( msg ProducerMessage ) ( [ ] byte , error ) { return json . Marshal ( msg ) } return MustSetupProducerWithSerializer ( brokers , defaultSerializer ) }
mustSetupProducer creates a producer for the kafka queues on brokers
brokers is a comma separated list of kafka nodes with host and ip, eg "172.0.0.1:9092,172.0.0.2:9092"
mustSetupProducer creates a producer for the kafka queues on brokers brokers is a comma separated list of kafka nodes with host and ip eg " 172 . 0 . 0 . 1 : 9092 172 . 0 . 0 . 2 : 9092 "