@@ -0,0 +1,1133 @@
+/**%0A * %3Cp%3ETitle: KafkaDestination.java%3C/p%3E%0A * %3Cp%3EDescription: KafkaDestination%3C/p%3E%0A * %3Cp%3EPackage: org.darkphoenixs.kafka.core%3C/p%3E%0A * %3Cp%3ECompany: www.github.com/DarkPhoenixs%3C/p%3E%0A * %3Cp%3ECopyright: Dark Phoenixs (Open-Source Organization) 2015%3C/p%3E%0A */%0Apackage org.darkphoenixs.kafka.core;%0A%0A/**%0A * %3Cp%3ETitle: KafkaDestination%3C/p%3E%0A * %3Cp%3EDescription: Kafka%E9%98%9F%E5%88%97%E5%AF%B9%E8%B1%A1%3C/p%3E%0A *%0A * @since 2015%E5%B9%B49%E6%9C%8812%E6%97%A5%0A * @author Victor%0A * @version 1.0%0A */%0Apublic class KafkaDestination %7B%0A%0A%09/** destinationName */%0A%09private String destinationName;%0A%09%0A%09/**%0A%09 * %3Cp%3ETitle: KafkaDestination%3C/p%3E%0A%09 * %3Cp%3EDescription: KafkaDestination%3C/p%3E%0A%09 */%0A%09public KafkaDestination() %7B%0A%09%7D%0A%09%0A%09/**%0A%09 * %3Cp%3ETitle: KafkaDestination%3C/p%3E%0A%09 * %3Cp%3EDescription: KafkaDestination%3C/p%3E%0A%09 *%0A%09 * @param destination destination%0A%09 */%0A%09public KafkaDestination(String destinationName) %7B%0A%09%09this.destinationName = destinationName;%0A%09%7D%0A%0A%09/**%0A%09 * @return the destinationName%0A%09 */%0A%09public String getDestinationName() %7B%0A%09%09return destinationName;%0A%09%7D%0A%0A%09/**%0A%09 * @param destinationName the destinationName to set%0A%09 */%0A%09public void setDestinationName(String destinationName) %7B%0A%09%09this.destinationName = destinationName;%0A%09%7D%0A%0A%7D%0A

Add 1.1