example: p, err := NewProducer(&resolver.ConfigMap{ "BOOTSTRAP_HOST": os.Getenv("KAFKA_BOOTSTRAP_HOST"), }).