I'm pretty sure the documented example for the merge generator has a slight typo/error in it. Comment in code here should be:
For clusters with a specific label, disable Kafka.