You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@servicecomb.apache.org by ni...@apache.org on 2019/08/17 00:06:24 UTC
[servicecomb-pack] 03/05: SCB-1442 add
KafkaChannelAutoConfiguration.newTopic
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 <42...@gmail.com>
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