example: p, err := NewConsumer[*model.Event](&resolver.ConfigMap{ "BOOTSTRAP_HOST": os.Getenv("KAFKA_BOOTSTRAP_HOST"), "REGISTRY_HOST": os.Getenv("KAFKA_REGISTRY_HOST"), // optional "GROUP_ID": "GROUP_ID", "PROCESSOR_COUNT": os.Getenv("KAFKA_PROCESSOR_COUNT"), "TOPIC": "TOPIC", }, subscribeListenerImpl).