feat: support otlp http binary protobuf format log data and update doc

hertzbeat-e2e/hertzbeat-log-e2e/src/test/java/org/apache/hertzbeat/log/storage/GreptimeLogStorageE2eTest.java

@@ -161,6 +161,6 @@ private List<LogEntry> queryStoredLogs() {
         long startTime = endTime - Duration.ofMinutes(5).toMillis(); // Look back 5 minutes
 
         return greptimeDbDataStorage.queryLogsByMultipleConditions(
-                startTime, endTime, null, null, null, null);
+                startTime, endTime, null, null, null, null, null);
     }
 }

hertzbeat-log/src/main/java/org/apache/hertzbeat/log/controller/LogIngestionController.java

@@ -17,6 +17,7 @@
 
 package org.apache.hertzbeat.log.controller;
 
+import io.swagger.v3.oas.annotations.Operation;
 import io.swagger.v3.oas.annotations.tags.Tag;
 import lombok.extern.slf4j.Slf4j;
 import java.util.List;
@@ -25,24 +26,25 @@
 import org.apache.hertzbeat.common.entity.dto.Message;
 import org.apache.hertzbeat.log.service.LogProtocolAdapter;
 import org.springframework.http.HttpStatus;
+import org.springframework.http.MediaType;
 import org.springframework.http.ResponseEntity;
-import org.springframework.util.StringUtils;
 import org.springframework.web.bind.annotation.PathVariable;
 import org.springframework.web.bind.annotation.PostMapping;
 import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
 
 /**
- * Log Ingestion Controller
+ * Generic Log Ingestion Controller
+ * Provides a fallback endpoint for log protocols that don't have dedicated controllers.
+ * For OTLP protocol, use OtlpLogController instead.
  */
 @Tag(name = "Log Ingestion Controller")
 @RestController
-@RequestMapping(path = "/api/logs", produces = "application/json")
+@RequestMapping(path = "/api/logs", produces = MediaType.APPLICATION_JSON_VALUE)
 @Slf4j
 public class LogIngestionController {
 
-    private static final String DEFAULT_PROTOCOL = "otlp";
     private final List<LogProtocolAdapter> protocolAdapters;
 
     public LogIngestionController(List<LogProtocolAdapter> protocolAdapters) {
@@ -51,26 +53,23 @@ public LogIngestionController(List<LogProtocolAdapter> protocolAdapters) {
 
     /**
      * Receive log payload pushed from external system specifying the log protocol.
-     * Examples:
-     *  - POST /api/logs/ingest/otlp         (content body is OTLP JSON)
      *
-     * @param protocol  log protocol identifier
-     * @param content raw request body
+     * @param protocol log protocol identifier (e.g., "vector", "loki")
+     * @param content  raw request body
      */
-    @PostMapping("/ingest/{protocol}")
-    public ResponseEntity<Message<Void>> ingestExternLog(@PathVariable("protocol") String protocol,
-                                                         @RequestBody String content) {
-        log.debug("Receive extern log from protocol: {}, content length: {}", protocol, content == null ? 0 : content.length());
-        if (!StringUtils.hasText(protocol)) {
-            protocol = DEFAULT_PROTOCOL; // Default to OTLP if no protocol specified
-        }
+    @Operation(summary = "Ingest logs by protocol name")
+    @PostMapping(value = "/ingest/{protocol}", consumes = MediaType.APPLICATION_JSON_VALUE)
+    public ResponseEntity<Message<Void>> ingestLog(@PathVariable("protocol") String protocol,
+                                                   @RequestBody String content) {
+        log.debug("Receive log from protocol: {}, content length: {}", protocol, content == null ? 0 : content.length());
+
         for (LogProtocolAdapter adapter : protocolAdapters) {
             if (adapter.supportProtocol().equalsIgnoreCase(protocol)) {
                 try {
                     adapter.ingest(content);
                     return ResponseEntity.ok(Message.success("Add extern log success"));
                 } catch (Exception e) {
-                    log.error("Add extern log failed: {}", e.getMessage(), e);
+                    log.error("Add log failed: {}", e.getMessage(), e);
                     return ResponseEntity.status(HttpStatus.BAD_REQUEST)
                             .body(Message.fail(CommonConstants.FAIL_CODE, "Add extern log failed: " + e.getMessage()));
                 }
@@ -80,30 +79,4 @@ public ResponseEntity<Message<Void>> ingestExternLog(@PathVariable("protocol") S
         return ResponseEntity.status(HttpStatus.BAD_REQUEST)
                 .body(Message.fail(CommonConstants.FAIL_CODE, "Not support the " + protocol + " protocol log"));
     }
-
-    /**
-     * Receive default log payload (when protocol is not specified).
-     * It will look for a service whose supportProtocol() returns "otlp".
-     */
-    @PostMapping("/ingest")
-    public ResponseEntity<Message<Void>> ingestDefaultExternLog(@RequestBody String content) {
-        log.info("Receive default extern log content, length: {}", content == null ? 0 : content.length());
-        LogProtocolAdapter adapter = protocolAdapters.stream()
-                .filter(item -> DEFAULT_PROTOCOL.equalsIgnoreCase(item.supportProtocol()))
-                .findFirst()
-                .orElse(null);
-        if (adapter != null) {
-            try {
-                adapter.ingest(content);
-                return ResponseEntity.ok(Message.success("Add extern log success"));
-            } catch (Exception e) {
-                log.error("Add extern log failed: {}", e.getMessage(), e);
-                return ResponseEntity.status(HttpStatus.BAD_REQUEST)
-                        .body(Message.fail(CommonConstants.FAIL_CODE, "Add extern log failed: " + e.getMessage()));
-            }
-        }
-        log.error("Not support default extern log protocol");
-        return ResponseEntity.status(HttpStatus.BAD_REQUEST)
-                .body(Message.fail(CommonConstants.FAIL_CODE, "Not support the default protocol log"));
-    }
 }