feat: Update: 1.upgrade version to v1.6(3.7.0.1.6); 2.update consumer…

… builder API.

Signed-off-by: photowey <photowey@gmail.com>

kafka-plus-autoconfigure/pom.xml

@@ -7,7 +7,7 @@
     <parent>
         <groupId>io.github.photowey</groupId>
         <artifactId>kafka-plus</artifactId>
-        <version>3.7.0.1.5</version>
+        <version>3.7.0.1.6-SNAPSHOT</version>
     </parent>
 
     <artifactId>kafka-plus-autoconfigure</artifactId>

kafka-plus-core/pom.xml

@@ -7,7 +7,7 @@
     <parent>
         <groupId>io.github.photowey</groupId>
         <artifactId>kafka-plus</artifactId>
-        <version>3.7.0.1.5</version>
+        <version>3.7.0.1.6-SNAPSHOT</version>
     </parent>
 
     <artifactId>kafka-plus-core</artifactId>

kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/clients/builder/consumer/ConsumerBuilder.java

@@ -183,6 +183,24 @@ default ConsumerBuilder strategy(Class<?> strategy) {
 
     // ----------------------------------------------------------------
 
+    /**
+     * Enhance custom property configs.
+     *
+     * @param fx the callback.
+     * @return {@link ConsumerBuilder}
+     */
+    ConsumerBuilder enhanceProps(Consumer<Properties> fx);
+
+    /**
+     * Enhance custom configs.
+     *
+     * @param fx the callback.
+     * @return {@link ConsumerBuilder}
+     */
+    ConsumerBuilder enhanceConfigs(Consumer<Map<String, Object>> fx);
+
+    // ----------------------------------------------------------------
+
     /**
      * Check custom property configs.
      *

kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/clients/builder/consumer/ConsumerBuilderImpl.java

@@ -164,6 +164,28 @@ public ConsumerBuilder configs(Map<String, Object> configs) {
 
     // ----------------------------------------------------------------
 
+    @Override
+    public ConsumerBuilder enhanceProps(Consumer<Properties> fx) {
+        checkNotNull("enhanceProps.fx", fx);
+        if (null != super.props) {
+            fx.accept(super.props);
+        }
+
+        return this;
+    }
+
+    @Override
+    public ConsumerBuilder enhanceConfigs(Consumer<Map<String, Object>> fx) {
+        checkNotNull("enhanceConfigs.fx", fx);
+        if (null != super.configs) {
+            fx.accept(super.configs);
+        }
+
+        return this;
+    }
+
+    // ----------------------------------------------------------------
+
     @Override
     public ConsumerBuilder checkProps(Consumer<Properties> fx) {
         checkNotNull("checkProps.fx", fx);

kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/clients/builder/producer/ProducerBuilder.java

@@ -274,15 +274,15 @@ default ProducerBuilder deliveryTimeoutMs(long timeout, TimeUnit unit) {
      * Check custom property configs.
      *
      * @param fx the callback.
-     * @return {@link ConsumerBuilder}
+     * @return {@link ProducerBuilder}
      */
     ProducerBuilder checkProps(Consumer<Properties> fx);
 
     /**
      * Check custom configs.
      *
      * @param fx the callback.
-     * @return {@link ConsumerBuilder}
+     * @return {@link ProducerBuilder}
      */
     ProducerBuilder checkConfigs(Consumer<Map<String, Object>> fx);
 

kafka-plus-engine/pom.xml

@@ -7,7 +7,7 @@
     <parent>
         <groupId>io.github.photowey</groupId>
         <artifactId>kafka-plus</artifactId>
-        <version>3.7.0.1.5</version>
+        <version>3.7.0.1.6-SNAPSHOT</version>
     </parent>
 
     <artifactId>kafka-plus-engine</artifactId>

kafka-plus-jackson/pom.xml

@@ -7,7 +7,7 @@
     <parent>
         <groupId>io.github.photowey</groupId>
         <artifactId>kafka-plus</artifactId>
-        <version>3.7.0.1.5</version>
+        <version>3.7.0.1.6-SNAPSHOT</version>
     </parent>
 
     <artifactId>kafka-plus-jackson</artifactId>

kafka-plus-runtime/pom.xml

@@ -7,7 +7,7 @@
     <parent>
         <groupId>io.github.photowey</groupId>
         <artifactId>kafka-plus</artifactId>
-        <version>3.7.0.1.5</version>
+        <version>3.7.0.1.6-SNAPSHOT</version>
     </parent>
 
     <artifactId>kafka-plus-runtime</artifactId>

kafkaplus-spring-boot-starter/pom.xml

@@ -7,7 +7,7 @@
     <parent>
         <groupId>io.github.photowey</groupId>
         <artifactId>kafka-plus</artifactId>
-        <version>3.7.0.1.5</version>
+        <version>3.7.0.1.6-SNAPSHOT</version>
     </parent>
 
     <artifactId>kafkaplus-spring-boot-starter</artifactId>

kafkaplus-spring-boot3-starter/pom.xml

@@ -7,7 +7,7 @@
     <parent>
         <groupId>io.github.photowey</groupId>
         <artifactId>kafka-plus</artifactId>
-        <version>3.7.0.1.5</version>
+        <version>3.7.0.1.6-SNAPSHOT</version>
     </parent>
 
     <artifactId>kafkaplus-spring-boot3-starter</artifactId>

pom.xml

@@ -7,7 +7,7 @@
     <groupId>io.github.photowey</groupId>
     <artifactId>kafka-plus</artifactId>
     <!-- ${kafka.version}.x.y -->
-    <version>3.7.0.1.5</version>
+    <version>3.7.0.1.6-SNAPSHOT</version>
     <packaging>pom</packaging>
 
     <name>${project.groupId}:${project.artifactId}</name>