This is an automated email from the ASF dual-hosted git repository.
mikexue pushed a change to branch config-manage-improve
in repository https://gitbox.apache.org/repos/asf/incubator-eventmesh.git
from 9d2ef643f Merge pull request #2637 from eight-nines/MR1
new 4b2444479 Improve configuration management of SPI implementations [1]
extensionInstance config init process improve [2] RocketMQProducerImpl and
RocketMQConsumerImpl config UT improve
new 06b85f096 Improve configuration management of Kafka SPI Impl [1]
KafkaConsumerImpl and KafkaProducerImpl config improve [2] KafkaConsumerImpl
and KafkaProducerImpl config UT
new da0cc821a Improve configuration management of Redis SPI Impl [1]
RedisProperties config improve
new e70e1491b Improve configuration management of Redis SPI Impl [1]
RedisProperties config and UT improve [2] New parser ConvertProperties [3] To
fix a bug where parser convertEnum could not parse null values
new 8e006df54 Fix config UT of Redis SPI Impl
new 027ebd5e2 Merge pull request #2680 from eight-nines/MR1
The 2497 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../eventmesh/common/config/ConfigService.java | 9 ++-
.../apache/eventmesh/common/config/FileLoad.java | 10 +--
.../org/apache/eventmesh/common/utils/Convert.java | 76 ++++++++++++++++------
.../kafka/config/ClientConfiguration.java | 37 ++++++++++-
.../kafka/consumer/KafkaConsumerImpl.java | 16 ++++-
.../kafka/producer/KafkaProducerImpl.java | 16 ++++-
.../kafka}/config/ClientConfigurationTest.java | 41 ++++++------
.../src/test/resources/kafka-client.properties | 30 +++++++++
.../connector/redis/client/RedissonClient.java | 62 ++++--------------
.../connector/redis/config/RedisProperties.java | 12 +++-
.../redis/config/RedisPropertiesTest.java | 47 +++++++++++++
.../src/test/resources/redis-client.properties | 7 +-
.../rocketmq/config/ClientConfiguration.java | 2 +-
.../rocketmq/config/ClientConfigurationTest.java | 24 +++----
.../eventmesh/spi/EventMeshExtensionFactory.java | 20 +++++-
15 files changed, 289 insertions(+), 120 deletions(-)
copy
eventmesh-connector-plugin/{eventmesh-connector-rocketmq/src/test/java/org/apache/eventmesh/connector/rocketmq
=>
eventmesh-connector-kafka/src/test/java/org/apache/eventmesh/connector/kafka}/config/ClientConfigurationTest.java
(63%)
create mode 100644
eventmesh-connector-plugin/eventmesh-connector-redis/src/test/java/org/apache/eventmesh/connector/redis/config/RedisPropertiesTest.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
