public void setOffsetManagement(OffsetManagement offsetManagement) {
		this.offsetManagement = offsetManagement;
	}
Set the {@link OffsetManagement} to use. Default:
{@link OffsetManagement#kafkaTopic}.
@param offsetManagement the offsetManagement.
spring-xd-messagebus-kafka/src/main/java/org/springframework/xd/dirt/integration/kafka/KafkaMessageBus.java