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 cf167571bbf7b8eb7488c8398d61d78b37ba93e3 Author: CMonkey <42.codemon...@gmail.com> AuthorDate: Wed Aug 14 10:12:17 2019 +0800 SCB-1418 add producer param to KafkaChannelAutoConfiguration --- .../fsm/channel/kafka/KafkaChannelAutoConfiguration.java | 16 +++++++++++++--- 1 file changed, 13 insertions(+), 3 deletions(-) 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 4f6569c..723a36e 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 @@ -61,6 +61,16 @@ public class KafkaChannelAutoConfiguration { @Value("${spring.kafka.consumer.properties.spring.json.trusted.packages:org.apache.servicecomb.pack.alpha.core.fsm.event,org.apache.servicecomb.pack.alpha.core.fsm.event.base,}org.apache.servicecomb.pack.alpha.core.fsm.event.internal") private String trusted_packages; + @Value("${spring.kafka.producer.batch-size:16384}") + private int batchSize; + + @Value("${spring.kafka.producer.retries:0}") + private int retries; + + @Value("${spring.kafka.producer.buffer.memory:33364432}") + private long bufferMemory; + + @Bean @ConditionalOnMissingBean public ProducerFactory<String, Object> producerFactory(){ @@ -68,9 +78,9 @@ public class KafkaChannelAutoConfiguration { map.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrap_servers); map.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class); map.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, JsonSerializer.class); - map.put(ProducerConfig.RETRIES_CONFIG, 0); - map.put(ProducerConfig.BATCH_SIZE_CONFIG, 16304); - map.put(ProducerConfig.BUFFER_MEMORY_CONFIG, 33354432); + map.put(ProducerConfig.RETRIES_CONFIG, retries); + map.put(ProducerConfig.BATCH_SIZE_CONFIG, batchSize); + map.put(ProducerConfig.BUFFER_MEMORY_CONFIG, bufferMemory); return new DefaultKafkaProducerFactory<>(map); }