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

Upgrade to SI 5.2.0.M4

Browse Source
This commit is contained in:
Gary Russell
2019-08-05 16:57:41 -04:00
parent 852c41d384
commit 0f1a75e2fe
67 changed files with 141 additions and 141 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -49,7 +49,7 @@ import org.springframework.kafka.listener.ContainerProperties;
import org.springframework.kafka.listener.KafkaMessageListenerContainer;
import org.springframework.kafka.support.KafkaHeaders;
import org.springframework.kafka.support.KafkaNull;
import org.springframework.kafka.support.TopicPartitionInitialOffset;
import org.springframework.kafka.support.TopicPartitionOffset;
import org.springframework.messaging.Message;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.MessageHandler;
@@ -134,7 +134,7 @@ public class Application {
public KafkaMessageListenerContainer<String, String> container(
ConsumerFactory<String, String> kafkaConsumerFactory) {
return new KafkaMessageListenerContainer<>(kafkaConsumerFactory,
new ContainerProperties(new TopicPartitionInitialOffset(this.properties.getTopic(), 0)));
new ContainerProperties(new TopicPartitionOffset(this.properties.getTopic(), 0)));
}
@Bean