Merge pull request #11 from photowey/release

[release] Release v1.5(v3.7.0.1.5)

docs/Kafka.3.7.0.md

@@ -0,0 +1,62 @@
+# `Kafka`
+
+## 1.Mode
+
+### 1.1.`Zookeeper`
+
+#### 1.1.1.`Node`
+
+- /admin
+    - delete_topics
+- /brokers
+    - ids
+        - 0
+        - …
+    - seqid
+    - topics
+        - `io.github.photowey.kafka.hello.topic`
+            - partition
+                - 0
+                - 1
+                - 2
+        - …
+- cluster
+    - id
+- config
+    - brokers
+    - **changes**
+    - clients
+    - ips
+    - topics
+        - `io.github.photowey.kafka.hello.topic`
+            - `{"version":1,"config":{}}`
+    - users
+- consumers
+- <font style="color:#FFCC66">controller</font>
+- `controller_eppch`
+- feature
+- **isr_change_notification**
+- latest_producer_id_block
+- **log_dir_event_notification**
+
+### 1.2.`KRaft`
+
+## 2.Producer
+
+### 2.1.Send
+
+1. Interceptors
+    1. main.thread
+2. Cluster Metadata
+    1. main.thread
+3. Serializer
+    1. main.thread
+4. Partitioner
+    1. main.thread
+5. RecordAccumulator
+    1. main.thread
+    2. sender.thread
+6. Sender
+    1. sender.thread
+7. NetworkClient
+    1. sender.thread

kafka-plus-autoconfigure/pom.xml

@@ -7,7 +7,7 @@
     <parent>
         <groupId>io.github.photowey</groupId>
         <artifactId>kafka-plus</artifactId>
-        <version>3.7.0.1.4</version>
+        <version>3.7.0.1.5</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.4</version>
+        <version>3.7.0.1.5</version>
     </parent>
 
     <artifactId>kafka-plus-core</artifactId>

kafka-plus-engine/pom.xml

@@ -7,7 +7,7 @@
     <parent>
         <groupId>io.github.photowey</groupId>
         <artifactId>kafka-plus</artifactId>
-        <version>3.7.0.1.4</version>
+        <version>3.7.0.1.5</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.4</version>
+        <version>3.7.0.1.5</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.4</version>
+        <version>3.7.0.1.5</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.4</version>
+        <version>3.7.0.1.5</version>
     </parent>
 
     <artifactId>kafkaplus-spring-boot-starter</artifactId>

kafkaplus-spring-boot-starter/src/main/java/io/github/photowey/kafka/plus/spring/boot/starter/config/KafkaPlusAutoConfigure.java

@@ -17,6 +17,8 @@
 
 import io.github.photowey.kafka.plus.autoconfigure.KafkaPlusConfigure;
 import io.github.photowey.kafka.plus.autoconfigure.core.property.KafkaPlusProperties;
+import org.springframework.boot.autoconfigure.AutoConfiguration;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
 import org.springframework.boot.context.properties.bind.Binder;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
@@ -27,14 +29,15 @@
  * {@code KafkaPlusAutoConfigure}
  *
  * @author photowey
- * @since 2024/04/06
  * @version 3.7.0.1.0
+ * @since 2024/04/06
  */
+@AutoConfiguration
 @Import(value = {
         KafkaPlusConfigure.class,
         KafkaPlusAutoConfigure.PropertyConfigure.class,
 })
-@Configuration
+@ConditionalOnClass(AutoConfiguration.class)
 public class KafkaPlusAutoConfigure {
 
     @Configuration

kafkaplus-spring-boot-starter/src/main/java/io/github/photowey/kafka/plus/spring/boot/starter/config/KafkaPlusConfigure.java

@@ -0,0 +1,55 @@
+/*
+ * Copyright © 2024 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package io.github.photowey.kafka.plus.spring.boot.starter.config;
+
+import io.github.photowey.kafka.plus.autoconfigure.core.property.KafkaPlusProperties;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingClass;
+import org.springframework.boot.context.properties.bind.Binder;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.Import;
+import org.springframework.core.env.Environment;
+
+/**
+ * {@code KafkaPlusConfigure}
+ *
+ * @author photowey
+ * @version 3.7.0.1.5
+ * @since 2024/04/06
+ */
+@Configuration
+@Import(value = {
+        io.github.photowey.kafka.plus.autoconfigure.KafkaPlusConfigure.class,
+        KafkaPlusConfigure.PropertyConfigure.class,
+})
+@ConditionalOnMissingClass("org.springframework.boot.autoconfigure.AutoConfiguration")
+public class KafkaPlusConfigure {
+
+    @Configuration
+    static class PropertyConfigure {
+
+        @Bean
+        public KafkaPlusProperties kafkaPlusProperties(Environment environment) {
+            return bind(environment, KafkaPlusProperties.getPrefix(), KafkaPlusProperties.class);
+        }
+    }
+
+    static <T> T bind(Environment environment, String prefix, Class<T> clazz) {
+        Binder binder = Binder.get(environment);
+
+        return binder.bind(prefix, clazz).get();
+    }
+}

kafkaplus-spring-boot-starter/src/main/resources/META-INF/spring.factories

@@ -1,2 +1,2 @@
 org.springframework.boot.autoconfigure.EnableAutoConfiguration=\
-io.github.photowey.kafka.plus.spring.boot.starter.config.KafkaPlusAutoConfigure
+io.github.photowey.kafka.plus.spring.boot.starter.config.KafkaPlusConfigure

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.4</version>
+        <version>3.7.0.1.5</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.4</version>
+    <version>3.7.0.1.5</version>
     <packaging>pom</packaging>
 
     <name>${project.groupId}:${project.artifactId}</name>