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:10 UTC
[servicecomb-pack] 14/21: SCB-1418 add consumer 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 189d8a1e208607d549543447cf96c408c9ada378
Author: CMonkey <42...@gmail.com>
AuthorDate: Wed Aug 14 10:20:31 2019 +0800
SCB-1418 add consumer param to KafkaChannelAutoConfiguration
---
.../fsm/channel/kafka/KafkaChannelAutoConfiguration.java | 14 +++++++++++---
1 file changed, 11 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 723a36e..ac38098 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
@@ -70,6 +70,14 @@ public class KafkaChannelAutoConfiguration {
@Value("${spring.kafka.producer.buffer.memory:33364432}")
private long bufferMemory;
+ @Value("${spring.kafka.consumer.auto.offset.reset:earliest}")
+ private String autoOffsetReset;
+
+ @Value("${spring.kafka.consumer.enable.auto.commit:true}")
+ private boolean enableAutoCommit;
+
+ @Value("${spring.kafka.consumer.auto.commit.interval.ms:100}")
+ private int autoCommitIntervalMs;
@Bean
@ConditionalOnMissingBean
@@ -100,9 +108,9 @@ public class KafkaChannelAutoConfiguration {
map.put(ConsumerConfig.GROUP_ID_CONFIG, groupId);
map.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class);
map.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, JsonDeserializer.class);
- map.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "earliest");
- map.put(ConsumerConfig.ENABLE_AUTO_COMMIT_CONFIG, true);
- map.put(ConsumerConfig.AUTO_COMMIT_INTERVAL_MS_CONFIG, 100);
+ map.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, autoOffsetReset);
+ map.put(ConsumerConfig.ENABLE_AUTO_COMMIT_CONFIG, enableAutoCommit);
+ map.put(ConsumerConfig.AUTO_COMMIT_INTERVAL_MS_CONFIG, autoCommitIntervalMs);
map.put(JsonDeserializer.TRUSTED_PACKAGES, trusted_packages);
if(logger.isDebugEnabled()){