@Override
	public String[] profilesToActivate() {
		if (offsetStorage != null) {
			return new String[] {String.format("%s-offset-manager", offsetStorage)};
		}
		else {
			throw new IllegalStateException("An offset storage strategy must be configured");
		}
	}
Module options for Kafka source module.

@author Ilayaperumal Gopinathan
@author Marius Bogoevici
extensions/spring-xd-extension-kafka/src/main/java/org/springframework/integration/x/kafka/KafkaSourceModuleOptionsMetadata.java