This is an automated email from the ASF dual-hosted git repository. ningjiang pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/servicecomb-pack.git
commit 0bc9c912c606e83d98f1ea19b4c1433f2027b602 Author: CMonkey <[email protected]> AuthorDate: Fri Aug 16 15:57:13 2019 +0800 SCB-1442 add KafkaChannelAutoConfiguration.newTopic --- .../fsm/channel/kafka/KafkaChannelAutoConfiguration.java | 13 +++++++++++++ 1 file changed, 13 insertions(+) diff --git a/alpha/alpha-fsm-channel-kafka/src/main/java/org/apache/servicecomb/pack/alpha/fsm/channel/kafka/KafkaChannelAutoConfiguration.java b/alpha/alpha-fsm-channel-kafka/src/main/java/org/apache/servicecomb/pack/alpha/fsm/channel/kafka/KafkaChannelAutoConfiguration.java index fe75a07..6729be6 100644 --- a/alpha/alpha-fsm-channel-kafka/src/main/java/org/apache/servicecomb/pack/alpha/fsm/channel/kafka/KafkaChannelAutoConfiguration.java +++ b/alpha/alpha-fsm-channel-kafka/src/main/java/org/apache/servicecomb/pack/alpha/fsm/channel/kafka/KafkaChannelAutoConfiguration.java @@ -18,6 +18,7 @@ package org.apache.servicecomb.pack.alpha.fsm.channel.kafka; import com.google.common.collect.Maps; import org.apache.kafka.clients.admin.AdminClientConfig; +import org.apache.kafka.clients.admin.NewTopic; import org.apache.kafka.clients.consumer.ConsumerConfig; import org.apache.kafka.clients.producer.ProducerConfig; import org.apache.kafka.common.serialization.StringDeserializer; @@ -87,6 +88,12 @@ public class KafkaChannelAutoConfiguration { @Value("${spring.kafka.listener.pollTimeout:1500}") private long poolTimeout; + @Value("${kafka.numPartitions:6}") + private int numPartitions; + + @Value("${kafka.replicationFactor:1}") + private short replicationFactor; + @Bean @ConditionalOnMissingBean public ProducerFactory<String, Object> producerFactory(){ @@ -159,4 +166,10 @@ public class KafkaChannelAutoConfiguration { return new KafkaAdmin(map); } + + @Bean + @ConditionalOnMissingBean + public NewTopic newTopic(){ + return new NewTopic(topic, numPartitions, replicationFactor); + } } \ No newline at end of file
