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 a5f89e9000a64883fecd73f2ebf78231fcd65ff6 Author: CMonkey <[email protected]> AuthorDate: Fri Aug 16 15:50:03 2019 +0800 SCB-1442 add kafkaAdmin to KafkaChannelAutoConfiguration --- .../fsm/channel/kafka/KafkaChannelAutoConfiguration.java | 11 +++++++++++ 1 file changed, 11 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 229c888..fe75a07 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 @@ -17,6 +17,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.consumer.ConsumerConfig; import org.apache.kafka.clients.producer.ProducerConfig; import org.apache.kafka.common.serialization.StringDeserializer; @@ -148,4 +149,14 @@ public class KafkaChannelAutoConfiguration { public KafkaMessageListener kafkaMessageListener(@Lazy @Qualifier("actorEventSink") ActorEventSink actorEventSink){ return new KafkaMessageListener(actorEventSink); } + + @Bean + @ConditionalOnMissingBean + public KafkaAdmin kafkaAdmin(){ + Map<String, Object> map = Maps.newHashMap(); + + map.put(AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrap_servers); + + return new KafkaAdmin(map); + } } \ No newline at end of file
