internal/model/log.go · 22159493d73673a59a723b4fe2b4d44ed661a21e · qiuqunfeng / waf-console

Implement Kafka log consumer with Elasticsearch and database integration · 22159493

qiuqunfeng authored Mar 01, 2025

- Add log consumer service to process WAF detection messages
- Implement message handling with JSON unmarshaling
- Save WAF detection logs to Elasticsearch
- Update WAF service attack number in database
- Modify ESStore to support bulk indexing with channel-based approach
- Add constants for Kafka topics and Elasticsearch indices

22159493

log.go 1.17 KB

Replace log.go