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

Kafka Samples - Provision Topics

Browse Source
This commit is contained in:
Gary Russell
2018-03-01 09:16:50 -05:00
parent e1929d1d3d
commit ac02700300
2 changed files with 32 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -1,5 +1,5 @@
/*
* Copyright 2015-2017 the original author or authors.
* Copyright 2015-2018 the original author or authors.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
@@ -19,6 +19,7 @@ package org.springframework.integration.samples.kafka;
import java.util.Collections;
import java.util.Map;
import org.apache.kafka.clients.admin.NewTopic;
import org.apache.kafka.clients.consumer.ConsumerConfig;
import org.apache.kafka.clients.producer.ProducerConfig;
@@ -150,6 +151,20 @@ public class Application {
return new QueueChannel();
}
/*
* Boot's autoconfigured KafkaAdmin will provision the topics.
*/
@Bean
public NewTopic topic(KafkaAppProperties properties) {
return new NewTopic(properties.getTopic(), 1, (short) 1);
}
@Bean
public NewTopic newTopic(KafkaAppProperties properties) {
return new NewTopic(properties.getNewTopic(), 1, (short) 1);
}
@Autowired
private IntegrationFlowContext flowContext;

17
dsl/kafka-dsl/src/main/java/org/springframework/integration/samples/dsl/kafka/Application.java
View File

@@ -1,5 +1,5 @@
/*
* Copyright 2016-2017 the original author or authors.
* Copyright 2016-2018 the original author or authors.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
@@ -18,6 +18,7 @@ package org.springframework.integration.samples.dsl.kafka;
import java.util.Map;
import org.apache.kafka.clients.admin.NewTopic;
import org.apache.kafka.clients.consumer.ConsumerConfig;
import org.springframework.beans.factory.annotation.Autowired;
@@ -115,6 +116,20 @@ public class Application {
.get();
}
/*
* Boot's autoconfigured KafkaAdmin will provision the topics.
*/
@Bean
public NewTopic topic(KafkaAppProperties properties) {
return new NewTopic(properties.getTopic(), 1, (short) 1);
}
@Bean
public NewTopic newTopic(KafkaAppProperties properties) {
return new NewTopic(properties.getNewTopic(), 1, (short) 1);
}
@Autowired
private IntegrationFlowContext flowContext;