perf: improve performance and optimizations in AutoMQ feature module

.editorconfig

@@ -16,6 +16,9 @@ trim_trailing_whitespace = false
 [*.yml]
 indent_size = 2
 
+[*.yaml]
+indent_size = 2
+
 [*.scala]
 indent_size = 2
 

.github/CODEOWNERS

@@ -13,4 +13,4 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 
-* @superhx @SCNieh @ShadowySpirits @Chillax-0v0
+* @superhx @Gezi-lzq @1sonofqiu @woshigaopp

.github/ISSUE_TEMPLATE/bug-report.yml

@@ -0,0 +1,105 @@
+name: "🐛 Bug Report"
+description: Report a problem or unexpected behavior in AutoMQ
+title: "[BUG] "
+labels: [bug]
+assignees: [your-github-username]
+body:
+  - type: markdown
+    attributes:
+      value: |
+        Thanks for reporting a bug. Please fill out the form below to help us diagnose and fix the issue.
+
+  - type: input
+    id: version
+    attributes:
+      label: AutoMQ Version
+      description: Run `automq --version` to find this.
+      placeholder: e.g., v0.1.0
+    validations:
+      required: true
+
+  - type: input
+    id: os
+    attributes:
+      label: Operating System
+      description: Use `uname` or check `/etc/os-release`.
+      placeholder: e.g., Ubuntu 20.04
+    validations:
+      required: true
+
+  - type: dropdown
+    id: install-method
+    attributes:
+      label: Installation Method
+      description: How did you install AutoMQ?
+      options:
+        - source
+        - binary
+        - docker
+        - package manager
+        - other
+    validations:
+      required: true
+
+  - type: textarea
+    id: hardware
+    attributes:
+      label: Hardware Configuration
+      description: Describe CPU, memory, disk, and other relevant hardware specs.
+      placeholder: e.g., 4-core CPU, 16GB RAM, SSD
+    validations:
+      required: false
+
+  - type: textarea
+    id: software
+    attributes:
+      label: Other Relevant Software
+      description: Include any additional tools or versions (e.g., Kafka version, monitoring tools).
+      placeholder: e.g., Kafka v3.6.0, Prometheus v2.45.0
+    validations:
+      required: false
+
+  - type: textarea
+    id: problem
+    attributes:
+      label: What Went Wrong?
+      description: Describe the unexpected behavior or error message.
+      placeholder: |
+        e.g. Broker crashes when receiving a large number of messages.
+        Error: "Connection refused: No available brokers"
+    validations:
+      required: true
+
+  - type: textarea
+    id: expected
+    attributes:
+      label: What Should Have Happened Instead?
+      description: Describe what you expected to happen.
+      placeholder: e.g., The broker should have handled the load gracefully.
+    validations:
+      required: true
+
+  - type: textarea
+    id: reproduction
+    attributes:
+      label: Steps to Reproduce
+      description: Provide step-by-step instructions to reproduce the issue.
+      placeholder: |
+        1. Start AutoMQ broker with default config.
+        2. Send a large number of messages.
+        3. Observe the broker behavior.
+    validations:
+      required: true
+
+  - type: textarea
+    id: additional
+    attributes:
+      label: Additional Information
+      description: Add logs, stack traces, metrics, configuration, or screenshots here.
+      placeholder: |
+        - Logs
+        - Backtraces
+        - Configuration files
+        - Screenshots
+    validations:
+      required: false

.github/ISSUE_TEMPLATE/feature-request.yml

@@ -0,0 +1,58 @@
+name: 🚀 Feature Request
+description: Suggest a new idea or improvement for AutoMQ
+title: "[Feature Request] "
+labels: 
+  - enhancement
+body:
+  - type: markdown
+    attributes:
+      value: |
+        Thanks for taking the time to suggest a feature! Please fill out the form below as clearly as possible.
+
+  - type: input
+    id: target-audience
+    attributes:
+      label: Who is this feature for?
+      description: Who are the users that would benefit from this feature?
+      placeholder: e.g. Engineers needing real-time AutoMQ monitoring
+    validations:
+      required: true
+
+  - type: textarea
+    id: current-problem
+    attributes:
+      label: What problem are they facing today?
+      description: Describe the issue or limitation they experience without this feature.
+      placeholder: e.g. No built-in dashboard to monitor metrics like throughput, latency, etc.
+    validations:
+      required: true
+
+  - type: textarea
+    id: impact
+    attributes:
+      label: Why is solving this impactful?
+      description: Explain the importance of this feature and how it benefits users, the project, or the community.
+      placeholder: e.g. Improves system visibility, reduces debugging time, enables proactive alerting...
+    validations:
+      required: true
+
+  - type: textarea
+    id: solution
+    attributes:
+      label: Proposed solution
+      description: Describe your proposed solution or idea in detail.
+      placeholder: |
+        - Web dashboard with real-time charts
+        - Accessible via the AutoMQ admin panel
+        - Uses minimal resources
+    validations:
+      required: true
+
+  - type: textarea
+    id: notes
+    attributes:
+      label: Additional notes
+      description: Add any related issues, dependencies, or initial work done.
+      placeholder: e.g. Related to issue #123, might require metrics export setup
+    validations:
+      required: false

.github/ISSUE_TEMPLATE/good-first-issue.yml

@@ -0,0 +1,56 @@
+name: "⭐ Good First Issue"
+description: Design and describe a task suitable for first-time contributors
+title: "[Good First Issue] "
+labels: [good first issue]
+assignees: [your-github-username]
+body:
+  - type: markdown
+    attributes:
+      value: |
+        Thank you for helping us make AutoMQ better for new contributors! Please fill out the details of this good first issue.
+
+  - type: textarea
+    id: background
+    attributes:
+      label: Background
+      description: Explain why this issue is being created and any relevant context.
+      placeholder: |
+        e.g. Currently, Kafka's logs are stored only on the local disk. We want to also store them in cloud object storage like S3 to improve reliability and enable querying.
+    validations:
+      required: true
+
+  - type: textarea
+    id: expectation
+    attributes:
+      label: What's Our Expectation for This Issue?
+      description: Describe what the desired outcome of this issue is.
+      placeholder: |
+        e.g. Log files should still exist locally, but also be uploaded to S3 using the following path format: s3://bucket-name/automq/cluster-id/broker-id/logs/xx
+    validations:
+      required: true
+
+  - type: textarea
+    id: getting-started
+    attributes:
+      label: How to Get Started
+      description: Help contributors understand how to begin working on the issue.
+      placeholder: |
+        - Precondition:
+            - Understand how AutoMQ writes logs to the local filesystem.
+        - Main Classes:
+            - `LogWriter`
+            - `CloudUploader`
+        - Tips:
+            - Refer to the `LogWriter` class to understand the current logic.
+    validations:
+      required: true
+
+  - type: textarea
+    id: references
+    attributes:
+      label: Reference Links
+      description: Include any helpful links, documents, or code references.
+      placeholder: |
+        e.g. [Kafka Official Documentation](https://kafka.apache.org/documentation/)
+    validations:
+      required: false

.github/workflows/auto-assign-issue.yml

@@ -0,0 +1,25 @@
+name: Auto Assign Issue
+on:
+  issue_comment:
+    types: [created]
+
+jobs:
+  assign-issue:
+    runs-on: ubuntu-latest
+    steps:
+      - name: Check if comment contains '/assign'
+        if: contains(github.event.comment.body, '/assign')
+        uses: actions/github-script@v6
+        with:
+          script: |
+            try {
+              await github.rest.issues.addAssignees({
+                owner: context.repo.owner,
+                repo: context.repo.repo,
+                issue_number: context.payload.issue.number,
+                assignees: [context.payload.comment.user.login]
+              });
+              console.log(`Assigned issue #${context.payload.issue.number} to @${context.payload.comment.user.login}`);
+            } catch (error) {
+              console.error('Error assigning issue:', error);
+            }

.github/workflows/build.yml

@@ -16,7 +16,7 @@
 name: Build
 on:
   pull_request:
-    types: [ opened, reopened, synchronize ]
+    types: [ opened, reopened, synchronize, ready_for_review ]
   push:
     branches: [ "main" ]
 

.github/workflows/build_automq.yml

@@ -49,7 +49,7 @@ jobs:
       - name: Setup Gradle
         uses: gradle/gradle-build-action@v2.9.0
       - name: Checkstyle
-        run: ./gradlew --build-cache rat checkstyleMain checkstyleTest
+        run: ./gradlew --build-cache rat checkstyleMain checkstyleTest spotlessJavaCheck
   spotbugs:
     name: "Spotbugs"
     runs-on: ${{ matrix.os }}