shishengliang/lingniu-vehicle-ingest
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

docs: align history troubleshooting comments

Browse Source
This commit is contained in:
lingniu
2026-07-01 04:24:48 +08:00
parent 02504de021
commit b8ee90a996
2 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
modules/protocols/protocol-gb32960/src/main/java/com/lingniu/ingest/protocol/gb32960/inbound/Gb32960ChannelHandler.java
View File

@@ -383,7 +383,8 @@ public class Gb32960ChannelHandler extends SimpleChannelInboundHandler<byte[]> {
* 部分车端实现严格按规范，没收到应答会停止后续上报或重连。ack-tag 按 cmd.code 区分便于日志筛选。 * 部分车端实现严格按规范，没收到应答会停止后续上报或重连。ack-tag 按 cmd.code 区分便于日志筛选。
* *
* <p>注意：应答成功表示当前配置的 Kafka sink 已完成该帧映射事件的 dispatch 边界。 * <p>注意：应答成功表示当前配置的 Kafka sink 已完成该帧映射事件的 dispatch 边界。
* 生产排查其他存储问题时，应继续检查 raw archive sink、EventFileStoreSink 等可选 sink 的日志。 * 生产排查历史数据问题时，应继续检查 raw archive sink、Kafka topic 和 history app 的
* TDengine raw_frames 写入日志。
* *
* <p>日志策略（按 (channel, vin, rawTypeSignature) 去重，避免高频帧刷屏）： * <p>日志策略（按 (channel, vin, rawTypeSignature) 去重，避免高频帧刷屏）：
* <ul> * <ul>

4
modules/sinks/sink-mq/src/main/java/com/lingniu/ingest/sink/mq/KafkaEnvelopeConsumerFactory.java
View File

@@ -62,8 +62,8 @@ public final class KafkaEnvelopeConsumerFactory {
if (configured != null && !configured.isEmpty()) { if (configured != null && !configured.isEmpty()) {
return configured; return configured;
} }
// 默认绑定保留老派生模块的消费能力；32960 主链路不依赖这些派生表， // 默认绑定仅给未显式配置 bindings 的轻量运行时兜底。
// 历史查询以 event-file-store 的 RAW 索引和 archive .bin 为准。 // 生产 history app 会显式绑定各协议 event/raw topic，并写入 TDengine raw_frames/locations。
SinkMqProperties.Topics topics = props.getTopics(); SinkMqProperties.Topics topics = props.getTopics();
Map<String, SinkMqProperties.Binding> defaults = new LinkedHashMap<>(); Map<String, SinkMqProperties.Binding> defaults = new LinkedHashMap<>();
defaults.put("eventHistoryEnvelopeConsumerProcessor", binding( defaults.put("eventHistoryEnvelopeConsumerProcessor", binding(