記 Kafka Consumer 消息阻塞
事件概述 最近在接入一個新的埋點 Kafka Topic 後,遇到一個非常隱蔽的問題: 新 Topic 一直消費不到消息; 在公司 MQ 平台上查看 Topic,查不到消費組的註冊信息; 日誌平台沒有任何 Error 日誌。 消費端的邏輯是典型的主動拉取模式,由異步線程循環執行: poll() 拉取一批消息; 事務處理(讀取消息、執行腳本、寫入存儲); commit 提交偏移量。
事件概述 最近在接入一個新的埋點 Kafka Topic 後,遇到一個非常隱蔽的問題: 新 Topic 一直消費不到消息; 在公司 MQ 平台上查看 Topic,查不到消費組的註冊信息; 日誌平台沒有任何 Error 日誌。 消費端的邏輯是典型的主動拉取模式,由異步線程循環執行: poll() 拉取一批消息; 事務處理(讀取消息、執行腳本、寫入存儲); commit 提交偏移量。
1. HNSW索引 分層可導航小世界 1.1. 定義 HNSW(Hierarchical Navigable Small World,分層可導航小世界)的核心思想是構建一個分層圖結構: 分層結構:每個數據點隨機分配一個層級,層級越高的數據點越少。 小世界圖:每層是一個“鄰接圖”,每個點只和部分點相連,圖結構保證“短路徑”導航。 導航:從高層開始,逐層向下搜索,逐步接近目標點。 生活類比
1. 前言 瞭解 SpringBoot 的人對內嵌 Tomcat 應該不陌生,內嵌 Tomcat 是指將 Tomcat Servlet 容器直接集成到應用程序中,作為應用的一部分運行,而不是作為一個獨立的外部服務器。 內嵌 Tomcat 通常通過添加相關的 Tomcat 依賴到項目中來實現。在 Java 應用啓動時,Tomcat 也會隨之啓動,成為應用的一部分。這是通過編程方式創建和配置 Tomc
1. JAX-RS 規範 JAX-RS(Java API for RESTful Web Services)是 Java 平台的一項規範,旨在為開發 RESTful Web 服務提供支持。JAX-RS 定義了一組標準的 API 和註解,使得開發者可以通過簡單的註解方式來開發基於 REST 架構風格的 Web 服務。 實現 JAX-RS 規範的產品有很多,例如:Oracle 開發的 Jersey、J