From 5401d1ca90bdc63b95543967b7fb0c7ed57db014 Mon Sep 17 00:00:00 2001 From: photowey Date: Mon, 8 Apr 2024 00:59:54 +0800 Subject: [PATCH 1/3] docs: Update java docs. --- .../core/clients/builder/AbstractBuilder.java | 7 + .../clients/builder/admin/AdminBuilder.java | 37 +++- .../builder/admin/AdminBuilderImpl.java | 7 +- .../builder/admin/topic/NewTopicBuilder.java | 35 ++++ .../builder/consumer/ConsumerBuilder.java | 109 +++++++++++ .../builder/producer/ProducerBuilder.java | 174 +++++++++++++++++- .../builder/record/ProducerRecordBuilder.java | 45 +++++ .../photowey/kafka/plus/core/enums/Kafka.java | 4 +- .../kafka/plus/engine/KafkaEngine.java | 2 +- pom.xml | 70 +++---- 10 files changed, 446 insertions(+), 44 deletions(-) diff --git a/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/clients/builder/AbstractBuilder.java b/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/clients/builder/AbstractBuilder.java index bf2c7fb..b7a583b 100644 --- a/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/clients/builder/AbstractBuilder.java +++ b/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/clients/builder/AbstractBuilder.java @@ -30,7 +30,14 @@ */ public abstract class AbstractBuilder { + /** + * The custom configs. + */ protected Map configs; + + /** + * The custom {@link Properties} configs. + */ protected Properties props; protected void initConfigsIfNecessary() { diff --git a/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/clients/builder/admin/AdminBuilder.java b/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/clients/builder/admin/AdminBuilder.java index 175aab0..e22a7f0 100644 --- a/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/clients/builder/admin/AdminBuilder.java +++ b/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/clients/builder/admin/AdminBuilder.java @@ -30,15 +30,50 @@ */ public interface AdminBuilder { + /** + * The {@code bootstrap.servers}. + * + * @param bootstrapServers the bootstrap.servers + * @return {@link AdminBuilder} + */ AdminBuilder boostrapServers(String bootstrapServers); + /** + * The custom property configs. + * + * @param props the custom property configs. + * @return {@link AdminBuilder} + */ AdminBuilder props(Properties props); - AdminBuilder configs(Map configMap); + /** + * The custom configs. + * + * @param configs the custom configs. + * @return {@link AdminBuilder} + */ + AdminBuilder configs(Map configs); + /** + * Check custom property configs. + * + * @param fx the callback. + * @return {@link AdminBuilder} + */ AdminBuilder checkProps(Consumer fx); + /** + * Check custom configs. + * + * @param fx the callback. + * @return {@link AdminBuilder} + */ AdminBuilder checkConfigs(Consumer> fx); + /** + * Build {@link Admin} instance. + * + * @return {@link Admin} + */ Admin build(); } diff --git a/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/clients/builder/admin/AdminBuilderImpl.java b/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/clients/builder/admin/AdminBuilderImpl.java index b6b119e..2df5729 100644 --- a/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/clients/builder/admin/AdminBuilderImpl.java +++ b/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/clients/builder/admin/AdminBuilderImpl.java @@ -31,15 +31,15 @@ * Properties props = new Properties(); * Admin admin = new AdminBuilderImpl() * .props(props) - * .checkProps((x) -> {}) + * .checkProps(x -> {}) * .build(); * * * 
- * Map configMap = new HashMap<>();
+ * Map<String, Object> configMap = new HashMap<>();
  * Admin admin = new AdminBuilderImpl()
  *    .configMap(configMap)
- *    .checkMap((x) -> {})
+ *    .checkConfigs(x -> {})
  *    .build();
  *
* @@ -47,7 +47,6 @@ * String bootstrapServers = "localhost:9092"; * Admin admin = new AdminBuilderImpl() * .boostrapServers(bootstrapServers) - * .checkMap((x) -> {}) * .build(); * * diff --git a/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/clients/builder/admin/topic/NewTopicBuilder.java b/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/clients/builder/admin/topic/NewTopicBuilder.java index 2ca6cc2..d8eebbe 100644 --- a/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/clients/builder/admin/topic/NewTopicBuilder.java +++ b/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/clients/builder/admin/topic/NewTopicBuilder.java @@ -29,15 +29,50 @@ */ public interface NewTopicBuilder { + /** + * The topic name. + * + * @param topic the topic name + * @return {@link NewTopicBuilder} + */ NewTopicBuilder topic(String topic); + /** + * The numPartitions. + * + * @param numPartitions the num of partitions. + * @return {@link NewTopicBuilder} + */ NewTopicBuilder numPartitions(Integer numPartitions); + /** + * The replicationFactor. + * + * @param replicationFactor the replication factor. + * @return {@link NewTopicBuilder} + */ NewTopicBuilder replicationFactor(Integer replicationFactor); + /** + * The replicasAssignments. + * + * @param replicasAssignments the replicas assignments. + * @return {@link NewTopicBuilder} + */ NewTopicBuilder replicasAssignments(Map> replicasAssignments); + /** + * The custom configs. + * + * @param configs the custom configs. + * @return {@link NewTopicBuilder} + */ NewTopicBuilder configs(Map configs); + /** + * Build {@link NewTopic} instance. + * + * @return {@link NewTopic} + */ NewTopic build(); } diff --git a/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/clients/builder/consumer/ConsumerBuilder.java b/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/clients/builder/consumer/ConsumerBuilder.java index dd5b46f..93e7357 100644 --- a/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/clients/builder/consumer/ConsumerBuilder.java +++ b/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/clients/builder/consumer/ConsumerBuilder.java @@ -31,51 +31,160 @@ */ public interface ConsumerBuilder { + /** + * The {@code bootstrap.servers}. + * + * @param bootstrapServers the bootstrap.servers + * @return {@link ConsumerBuilder} + */ ConsumerBuilder boostrapServers(String bootstrapServers); + /** + * The key deserializer. + * + * @param keyDeserializer the key deserializer Class. + * @param the key type. + * @return {@link ConsumerBuilder} + */ default ConsumerBuilder keyDeserializer(Class keyDeserializer) { return this.keyDeserializer(keyDeserializer.getName()); } + /** + * The value deserializer. + * + * @param valueDeserializer the value deserializer Class. + * @param the value type. + * @return {@link ConsumerBuilder} + */ default ConsumerBuilder valueDeserializer(Class valueDeserializer) { return this.valueDeserializer(valueDeserializer.getName()); } + /** + * The key deserializer. + * + * @param keyDeserializer the key deserializer. + * @return {@link ConsumerBuilder} + */ ConsumerBuilder keyDeserializer(String keyDeserializer); + /** + * The value deserializer. + * + * @param valueDeserializer the value deserializer. + * @return {@link ConsumerBuilder} + */ ConsumerBuilder valueDeserializer(String valueDeserializer); + /** + * The {@code auto.offset.reset}. + * + * @param offsetReset the {@code auto.offset.reset} + * @return {@link ConsumerBuilder} + */ ConsumerBuilder autoOffsetReset(Kafka.Consumer.AutoOffsetReset offsetReset); + /** + * The {@code group.id}. + * + * @param groupId the {@code group.id} + * @return {@link ConsumerBuilder} + */ ConsumerBuilder groupId(String groupId); + /** + * The {@code enable.auto.commit}. + * + * @param enabled the {@code enable.auto.commit} + * @return {@link ConsumerBuilder} + */ ConsumerBuilder autoCommit(boolean enabled); // ---------------------------------------------------------------- + /** + * The key deserializer. + * + * @param keyDeserializer the key deserializer. + * @param the key type. + * @return {@link ConsumerBuilder} + */ ConsumerBuilder keyDeserializer(Deserializer keyDeserializer); + /** + * The value deserializer. + * + * @param valueDeserializer the value deserializer. + * @param the value type. + * @return {@link ConsumerBuilder} + */ ConsumerBuilder valueDeserializer(Deserializer valueDeserializer); // ---------------------------------------------------------------- + + /** + * The custom property configs. + * + * @param props the custom property configs. + * @return {@link ConsumerBuilder} + */ ConsumerBuilder props(Properties props); + /** + * The custom configs. + * + * @param configs the custom configs. + * @return {@link ConsumerBuilder} + */ ConsumerBuilder configs(Map configs); // ---------------------------------------------------------------- + /** + * Check custom property configs. + * + * @param fx the callback. + * @return {@link ConsumerBuilder} + */ ConsumerBuilder checkProps(Consumer fx); + /** + * Check custom configs. + * + * @param fx the callback. + * @return {@link ConsumerBuilder} + */ ConsumerBuilder checkConfigs(Consumer> fx); // ---------------------------------------------------------------- + + /** + * The topics of the consumer subscribe. + * + * @param topics the topic names. + * @return {@link ConsumerBuilder} + */ default ConsumerBuilder subscribe(String... topics) { return this.subscribe(new HashSet<>(Arrays.asList(topics))); } + /** + * The topics of the consumer subscribe. + * + * @param topics the topic names. + * @return {@link ConsumerBuilder} + */ ConsumerBuilder subscribe(Collection topics); // ---------------------------------------------------------------- + /** + * Build {@link KafkaConsumer} instance. + * + * @param the key type. + * @param the value type. + * @return {@link KafkaConsumer} + */ KafkaConsumer build(); } diff --git a/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/clients/builder/producer/ProducerBuilder.java b/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/clients/builder/producer/ProducerBuilder.java index b7e9974..ab88217 100644 --- a/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/clients/builder/producer/ProducerBuilder.java +++ b/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/clients/builder/producer/ProducerBuilder.java @@ -15,6 +15,7 @@ */ package io.github.photowey.kafka.plus.core.clients.builder.producer; +import io.github.photowey.kafka.plus.core.clients.builder.consumer.ConsumerBuilder; import io.github.photowey.kafka.plus.core.enums.Kafka; import org.apache.kafka.clients.producer.KafkaProducer; import org.apache.kafka.clients.producer.Partitioner; @@ -35,72 +36,218 @@ */ public interface ProducerBuilder { + /** + * The {@code bootstrap.servers}. + * + * @param bootstrapServers the bootstrap.servers + * @return {@link ProducerBuilder} + */ ProducerBuilder boostrapServers(String bootstrapServers); // ---------------------------------------------------------------- + /** + * The key serializer. + * + * @param keySerializer the key serializer. + * @param the key type. + * @return {@link ProducerBuilder} + */ ProducerBuilder keySerializer(Serializer keySerializer); - + /** + * The value serializer. + * + * @param valueSerializer the value serializer. + * @param the value type. + * @return {@link ProducerBuilder} + */ ProducerBuilder valueSerializer(Serializer valueSerializer); + /** + * The key serializer. + * + * @param keySerializer the key serializer Class. + * @param the key type. + * @return {@link ProducerBuilder} + */ default ProducerBuilder keySerializer(Class keySerializer) { return this.keySerializer(keySerializer.getName()); } + /** + * The value serializer. + * + * @param valueSerializer the value serializer Class. + * @param the value type. + * @return {@link ProducerBuilder} + */ default ProducerBuilder valueSerializer(Class valueSerializer) { return this.valueSerializer(valueSerializer.getName()); } + /** + * The key serializer. + * + * @param keySerializer the key serializer. + * @return {@link ProducerBuilder} + */ ProducerBuilder keySerializer(String keySerializer); + /** + * The value serializer. + * + * @param valueSerializer the value serializer. + * @return {@link ProducerBuilder} + */ ProducerBuilder valueSerializer(String valueSerializer); // ---------------------------------------------------------------- + + /** + * The custom property configs. + * + * @param props the custom property configs. + * @return {@link ConsumerBuilder} + */ ProducerBuilder props(Properties props); + /** + * The custom configs. + * + * @param configs the custom configs. + * @return {@link ConsumerBuilder} + */ ProducerBuilder configs(Map configs); // ---------------------------------------------------------------- + /** + * Enhance custom property configs. + * + * @param fx the callback. + * @return {@link ConsumerBuilder} + */ ProducerBuilder enhanceProps(Consumer fx); + /** + * Enhance custom configs. + * + * @param fx the callback. + * @return {@link ConsumerBuilder} + */ ProducerBuilder enhanceConfigs(Consumer> fx); // ---------------------------------------------------------------- + /** + * The interceptor. + * + * @param interceptor the interceptor Class + * @param the key type. + * @param the value type. + * @param the {@link ProducerInterceptor} type. + * @return {@link ProducerBuilder} + */ default > ProducerBuilder interceptor(Class interceptor) { return this.interceptor(interceptor.getName()); } + /** + * The partitioner. + * + * @param partitioner the partitioner Class. + * @param

the partitioner type. + * @return {@link ProducerBuilder} + */ default

ProducerBuilder partitioner(Class

partitioner) { return this.partitioner(partitioner.getName()); } + /** + * The interceptor. + * + * @param interceptor the interceptor Class name + * @return {@link ProducerBuilder} + */ ProducerBuilder interceptor(String interceptor); + /** + * The partitioner. + * + * @param partitioner the partitioner Class name. + * @return {@link ProducerBuilder} + */ ProducerBuilder partitioner(String partitioner); // ---------------------------------------------------------------- + /** + * The {@code acks}. + * + * @param acks {@code acks}. + * @return {@link ProducerBuilder} + */ ProducerBuilder acks(Kafka.Producer.Acks acks); + /** + * The {@code retries}. + * + * @param retries {@code retries}. + * @return {@link ProducerBuilder} + */ ProducerBuilder retries(long retries); // ---------------------------------------------------------------- + /** + * The {@code batch.size}. + * + * @param batchSize the batch size. + * @return {@link ProducerBuilder} + */ ProducerBuilder batchSize(long batchSize); + /** + * The {@code buffer.memory}. + * + * @param bufferMemorySize the buffer memory size. + * @return {@link ProducerBuilder} + */ ProducerBuilder bufferMemorySize(long bufferMemorySize); // ---------------------------------------------------------------- + /** + * The {@code linger.ms}. + * + * @param millis {@code linger.ms}. + * @return {@link ProducerBuilder} + */ ProducerBuilder lingerMs(long millis); + /** + * The {@code max.block.ms}. + * + * @param millis {@code max.block.ms}. + * @return {@link ProducerBuilder} + */ ProducerBuilder maxBlockMs(long millis); + /** + * The {@code request.timeout.ms}. + * + * @param millis {@code request.timeout.ms}. + * @return {@link ProducerBuilder} + */ ProducerBuilder requestTimeoutMs(long millis); + /** + * The {@code delivery.timeout.ms}. + * + * @param millis {@code delivery.timeout.ms}. + * @return {@link ProducerBuilder} + */ ProducerBuilder deliveryTimeoutMs(long millis); default ProducerBuilder requestTimeoutMs(long timeout, TimeUnit unit) { @@ -113,15 +260,40 @@ default ProducerBuilder deliveryTimeoutMs(long timeout, TimeUnit unit) { // ---------------------------------------------------------------- + /** + * The {@code enable.idempotence}. + * + * @param enabled {@code enable.idempotence}. + * @return {@link ProducerBuilder} + */ ProducerBuilder idempotence(boolean enabled); // ---------------------------------------------------------------- + /** + * Check custom property configs. + * + * @param fx the callback. + * @return {@link ConsumerBuilder} + */ ProducerBuilder checkProps(Consumer fx); + /** + * Check custom configs. + * + * @param fx the callback. + * @return {@link ConsumerBuilder} + */ ProducerBuilder checkConfigs(Consumer> fx); // ---------------------------------------------------------------- + /** + * Build {@link KafkaProducer} instance. + * + * @param the key type. + * @param the value type. + * @return {@link KafkaProducer} + */ KafkaProducer build(); } \ No newline at end of file diff --git a/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/clients/builder/record/ProducerRecordBuilder.java b/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/clients/builder/record/ProducerRecordBuilder.java index a552d21..b31b0ff 100644 --- a/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/clients/builder/record/ProducerRecordBuilder.java +++ b/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/clients/builder/record/ProducerRecordBuilder.java @@ -27,17 +27,62 @@ */ public interface ProducerRecordBuilder { + /** + * The topic name. + * + * @param topic the topic name. + * @return {@link ProducerRecordBuilder} + */ ProducerRecordBuilder topic(String topic); + /** + * The partition number. + * + * @param partition the partition number. + * @return {@link ProducerRecordBuilder} + */ ProducerRecordBuilder partition(Integer partition); + /** + * The headers. + * + * @param headers the headers. + * @return {@link ProducerRecordBuilder} + */ ProducerRecordBuilder headers(Iterable

headers); + /** + * The key. + * + * @param key the record key. + * @param the key type. + * @return {@link ProducerRecordBuilder} + */ ProducerRecordBuilder key(K key); + /** + * The value. + * + * @param value the record value. + * @param the value type. + * @return {@link ProducerRecordBuilder} + */ ProducerRecordBuilder value(V value); + /** + * The timestamp. + * + * @param timestamp the timestamp. + * @return {@link ProducerRecordBuilder} + */ ProducerRecordBuilder timestamp(Long timestamp); + /** + * Build {@link ProducerRecord} instance. + * + * @param the key type. + * @param the value type. + * @return {@link ProducerRecord} + */ ProducerRecord build(); } diff --git a/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/enums/Kafka.java b/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/enums/Kafka.java index 0664130..ac11e38 100644 --- a/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/enums/Kafka.java +++ b/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/enums/Kafka.java @@ -147,8 +147,8 @@ public enum Producer { DELIVERY_TIMEOUT_MS("An upper bound on the time to report success or failure", ProducerConfig.DELIVERY_TIMEOUT_MS_CONFIG), /** - * @see Producer#ACKS (== -1) - * @see Producer#RETRIES (> 0) + * @see Producer#ACKS (== 0) + * @see Producer#RETRIES (> 0) */ IDEMPOTENCE_ENABLED(ProducerConfig.ENABLE_IDEMPOTENCE_DOC, ProducerConfig.ENABLE_IDEMPOTENCE_CONFIG), diff --git a/kafka-plus-engine/src/main/java/io/github/photowey/kafka/plus/engine/KafkaEngine.java b/kafka-plus-engine/src/main/java/io/github/photowey/kafka/plus/engine/KafkaEngine.java index 085c3e9..6192536 100644 --- a/kafka-plus-engine/src/main/java/io/github/photowey/kafka/plus/engine/KafkaEngine.java +++ b/kafka-plus-engine/src/main/java/io/github/photowey/kafka/plus/engine/KafkaEngine.java @@ -33,7 +33,7 @@ public interface KafkaEngine extends Engine { * 
      * try (Admin admin = KafkaEngineHolder.INSTANCE.kafkaEngine().adminService().createAdmin()
      *        .boostrapServers("localhost:9092")
-     *        .checkMap((x) -> {})
+     *        .checkMap((x) -> {})
      *        .create()) {
      *    // do something.
      * }
diff --git a/pom.xml b/pom.xml
index 38cf90b..e9dcec1 100644
--- a/pom.xml
+++ b/pom.xml
@@ -175,6 +175,41 @@
                 maven-surefire-plugin
                 ${maven-surefire-plugin.version}
             
+            
+                org.apache.maven.plugins
+                maven-source-plugin
+                ${maven-source-plugin.version}
+                
+                    
+                        attach-sources
+                        
+                            jar-no-fork
+                        
+                    
+                
+            
+            
+                org.apache.maven.plugins
+                maven-javadoc-plugin
+                ${maven-javadoc-plugin.version}
+                
+                    
+                        
+                            date
+                            a
+                            Create time
+                        
+                    
+                
+                
+                    
+                        attach-javadocs
+                        
+                            jar
+                        
+                    
+                
+            
             
                 org.apache.maven.plugins
                 maven-release-plugin
@@ -276,41 +311,6 @@ limitations under the License.
                             true
                         
                     
-                    
-                        org.apache.maven.plugins
-                        maven-source-plugin
-                        ${maven-source-plugin.version}
-                        
-                            
-                                attach-sources
-                                
-                                    jar-no-fork
-                                
-                            
-                        
-                    
-                    
-                        org.apache.maven.plugins
-                        maven-javadoc-plugin
-                        ${maven-javadoc-plugin.version}
-                        
-                            
-                                
-                                    date
-                                    a
-                                    Create time
-                                
-                            
-                        
-                        
-                            
-                                attach-javadocs
-                                
-                                    jar
-                                
-                            
-                        
-                    
                     
                         org.apache.maven.plugins
                         maven-gpg-plugin

From 685753647309e3fe0bb46f8683d76ca324d45d5f Mon Sep 17 00:00:00 2001
From: photowey 
Date: Mon, 8 Apr 2024 01:02:24 +0800
Subject: [PATCH 2/3] docs: Update version to 3.7.0.1.1

Signed-off-by: photowey 
---
 kafka-plus-autoconfigure/pom.xml       | 2 +-
 kafka-plus-core/pom.xml                | 2 +-
 kafka-plus-engine/pom.xml              | 2 +-
 kafka-plus-jackson/pom.xml             | 2 +-
 kafka-plus-runtime/pom.xml             | 2 +-
 kafkaplus-spring-boot-starter/pom.xml  | 2 +-
 kafkaplus-spring-boot3-starter/pom.xml | 2 +-
 pom.xml                                | 2 +-
 8 files changed, 8 insertions(+), 8 deletions(-)

diff --git a/kafka-plus-autoconfigure/pom.xml b/kafka-plus-autoconfigure/pom.xml
index b81d1ab..318312a 100644
--- a/kafka-plus-autoconfigure/pom.xml
+++ b/kafka-plus-autoconfigure/pom.xml
@@ -7,7 +7,7 @@
     
         io.github.photowey
         kafka-plus
-        3.7.0.1.0
+        3.7.0.1.1-SNAPSHOT
     
 
     kafka-plus-autoconfigure
diff --git a/kafka-plus-core/pom.xml b/kafka-plus-core/pom.xml
index 5142ec1..77ad374 100644
--- a/kafka-plus-core/pom.xml
+++ b/kafka-plus-core/pom.xml
@@ -7,7 +7,7 @@
     
         io.github.photowey
         kafka-plus
-        3.7.0.1.0
+        3.7.0.1.1-SNAPSHOT
     
 
     kafka-plus-core
diff --git a/kafka-plus-engine/pom.xml b/kafka-plus-engine/pom.xml
index 61e1cde..13f1061 100644
--- a/kafka-plus-engine/pom.xml
+++ b/kafka-plus-engine/pom.xml
@@ -7,7 +7,7 @@
     
         io.github.photowey
         kafka-plus
-        3.7.0.1.0
+        3.7.0.1.1-SNAPSHOT
     
 
     kafka-plus-engine
diff --git a/kafka-plus-jackson/pom.xml b/kafka-plus-jackson/pom.xml
index eb998bc..0dc4c65 100644
--- a/kafka-plus-jackson/pom.xml
+++ b/kafka-plus-jackson/pom.xml
@@ -7,7 +7,7 @@
     
         io.github.photowey
         kafka-plus
-        3.7.0.1.0
+        3.7.0.1.1-SNAPSHOT
     
 
     kafka-plus-jackson
diff --git a/kafka-plus-runtime/pom.xml b/kafka-plus-runtime/pom.xml
index 5f2bf2e..1f66e13 100644
--- a/kafka-plus-runtime/pom.xml
+++ b/kafka-plus-runtime/pom.xml
@@ -7,7 +7,7 @@
     
         io.github.photowey
         kafka-plus
-        3.7.0.1.0
+        3.7.0.1.1-SNAPSHOT
     
 
     kafka-plus-runtime
diff --git a/kafkaplus-spring-boot-starter/pom.xml b/kafkaplus-spring-boot-starter/pom.xml
index c071552..c93aa62 100644
--- a/kafkaplus-spring-boot-starter/pom.xml
+++ b/kafkaplus-spring-boot-starter/pom.xml
@@ -7,7 +7,7 @@
     
         io.github.photowey
         kafka-plus
-        3.7.0.1.0
+        3.7.0.1.1-SNAPSHOT
     
 
     kafkaplus-spring-boot-starter
diff --git a/kafkaplus-spring-boot3-starter/pom.xml b/kafkaplus-spring-boot3-starter/pom.xml
index 289f9a3..d61beff 100644
--- a/kafkaplus-spring-boot3-starter/pom.xml
+++ b/kafkaplus-spring-boot3-starter/pom.xml
@@ -7,7 +7,7 @@
     
         io.github.photowey
         kafka-plus
-        3.7.0.1.0
+        3.7.0.1.1-SNAPSHOT
     
 
     kafkaplus-spring-boot3-starter
diff --git a/pom.xml b/pom.xml
index e9dcec1..d050c09 100644
--- a/pom.xml
+++ b/pom.xml
@@ -13,7 +13,7 @@
     io.github.photowey
     kafka-plus
     
-    3.7.0.1.0
+    3.7.0.1.1-SNAPSHOT
     pom
 
     ${project.groupId}:${project.artifactId}

From 65e828e30cbf7ddcd6c45fb0a011e762a853bbc6 Mon Sep 17 00:00:00 2001
From: photowey 
Date: Mon, 8 Apr 2024 01:04:10 +0800
Subject: [PATCH 3/3] refactor: release v1.0(3.7.0.1.1)

Signed-off-by: photowey 
---
 kafka-plus-autoconfigure/pom.xml       | 2 +-
 kafka-plus-core/pom.xml                | 2 +-
 kafka-plus-engine/pom.xml              | 2 +-
 kafka-plus-jackson/pom.xml             | 2 +-
 kafka-plus-runtime/pom.xml             | 2 +-
 kafkaplus-spring-boot-starter/pom.xml  | 2 +-
 kafkaplus-spring-boot3-starter/pom.xml | 2 +-
 pom.xml                                | 2 +-
 8 files changed, 8 insertions(+), 8 deletions(-)

diff --git a/kafka-plus-autoconfigure/pom.xml b/kafka-plus-autoconfigure/pom.xml
index 318312a..892becf 100644
--- a/kafka-plus-autoconfigure/pom.xml
+++ b/kafka-plus-autoconfigure/pom.xml
@@ -7,7 +7,7 @@
     
         io.github.photowey
         kafka-plus
-        3.7.0.1.1-SNAPSHOT
+        3.7.0.1.1
     
 
     kafka-plus-autoconfigure
diff --git a/kafka-plus-core/pom.xml b/kafka-plus-core/pom.xml
index 77ad374..35dbdaf 100644
--- a/kafka-plus-core/pom.xml
+++ b/kafka-plus-core/pom.xml
@@ -7,7 +7,7 @@
     
         io.github.photowey
         kafka-plus
-        3.7.0.1.1-SNAPSHOT
+        3.7.0.1.1
     
 
     kafka-plus-core
diff --git a/kafka-plus-engine/pom.xml b/kafka-plus-engine/pom.xml
index 13f1061..94907b4 100644
--- a/kafka-plus-engine/pom.xml
+++ b/kafka-plus-engine/pom.xml
@@ -7,7 +7,7 @@
     
         io.github.photowey
         kafka-plus
-        3.7.0.1.1-SNAPSHOT
+        3.7.0.1.1
     
 
     kafka-plus-engine
diff --git a/kafka-plus-jackson/pom.xml b/kafka-plus-jackson/pom.xml
index 0dc4c65..af3da9a 100644
--- a/kafka-plus-jackson/pom.xml
+++ b/kafka-plus-jackson/pom.xml
@@ -7,7 +7,7 @@
     
         io.github.photowey
         kafka-plus
-        3.7.0.1.1-SNAPSHOT
+        3.7.0.1.1
     
 
     kafka-plus-jackson
diff --git a/kafka-plus-runtime/pom.xml b/kafka-plus-runtime/pom.xml
index 1f66e13..b24e823 100644
--- a/kafka-plus-runtime/pom.xml
+++ b/kafka-plus-runtime/pom.xml
@@ -7,7 +7,7 @@
     
         io.github.photowey
         kafka-plus
-        3.7.0.1.1-SNAPSHOT
+        3.7.0.1.1
     
 
     kafka-plus-runtime
diff --git a/kafkaplus-spring-boot-starter/pom.xml b/kafkaplus-spring-boot-starter/pom.xml
index c93aa62..afbf638 100644
--- a/kafkaplus-spring-boot-starter/pom.xml
+++ b/kafkaplus-spring-boot-starter/pom.xml
@@ -7,7 +7,7 @@
     
         io.github.photowey
         kafka-plus
-        3.7.0.1.1-SNAPSHOT
+        3.7.0.1.1
     
 
     kafkaplus-spring-boot-starter
diff --git a/kafkaplus-spring-boot3-starter/pom.xml b/kafkaplus-spring-boot3-starter/pom.xml
index d61beff..04e9df9 100644
--- a/kafkaplus-spring-boot3-starter/pom.xml
+++ b/kafkaplus-spring-boot3-starter/pom.xml
@@ -7,7 +7,7 @@
     
         io.github.photowey
         kafka-plus
-        3.7.0.1.1-SNAPSHOT
+        3.7.0.1.1
     
 
     kafkaplus-spring-boot3-starter
diff --git a/pom.xml b/pom.xml
index d050c09..c5518ab 100644
--- a/pom.xml
+++ b/pom.xml
@@ -13,7 +13,7 @@
     io.github.photowey
     kafka-plus
     
-    3.7.0.1.1-SNAPSHOT
+    3.7.0.1.1
     pom
 
     ${project.groupId}:${project.artifactId}