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/14 11:41:09 UTC
[servicecomb-pack] 13/21: SCB-1418 add producer param to
KafkaChannelAutoConfiguration
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...@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);
}