Spring/spring-integration-samples
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Some upgrades

Browse Source 
* Gradle-2.13
* Spring Kafka 1.0.0.RC1
* Spring Integration Kafka 2.0.0.RC1
* Spring Boot 1.4.0.M3
* Provide required fixes
This commit is contained in:
Artem Bilan
2016-06-06 21:12:55 -04:00
parent b6f872664d
commit 1cbcbe7810
9 changed files with 62 additions and 59 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
basic/kafka/src/main/java/org/springframework/integration/samples/kafka/Application.java
View File

@@ -23,7 +23,6 @@ import java.util.Properties;
import org.I0Itec.zkclient.ZkClient;
import org.apache.kafka.clients.consumer.ConsumerConfig;
import org.apache.kafka.clients.producer.ProducerConfig;
import org.apache.kafka.common.TopicPartition;
import org.apache.kafka.common.serialization.StringDeserializer;
import org.apache.kafka.common.serialization.StringSerializer;
@@ -44,6 +43,8 @@ import org.springframework.kafka.core.DefaultKafkaProducerFactory;
import org.springframework.kafka.core.KafkaTemplate;
import org.springframework.kafka.core.ProducerFactory;
import org.springframework.kafka.listener.KafkaMessageListenerContainer;
import org.springframework.kafka.listener.config.ContainerProperties;
import org.springframework.kafka.support.TopicPartitionInitialOffset;
import org.springframework.messaging.Message;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.MessageHandler;
@@ -123,7 +124,8 @@ public class Application {
@Bean
public KafkaMessageListenerContainer<String, String> container() throws Exception {
return new KafkaMessageListenerContainer<>(consumerFactory(), new TopicPartition(this.topic, 0));
return new KafkaMessageListenerContainer<>(consumerFactory(),
new ContainerProperties(new TopicPartitionInitialOffset(this.topic, 0)));
}
@Bean