# zhaoxuan/kafka2elasticsearch

> Subscribe to the Kafka cluster of a topic data into es, and according to the subscription log content product, event_time create index index name is aqueducts_product_ year month day, type determined by service

- **Canonical URL**: https://githubrepo.cloud/repo/zhaoxuan/kafka2elasticsearch
- **GitHub Repository**: https://github.com/zhaoxuan/kafka2elasticsearch
- **Maintainer / Creator**: https://github.com/zhaoxuan
- **Discovered On**: Oct 3, 2026

---
*Indexed by GitHubRepo (https://githubrepo.cloud). Real-time open-source discovery & telemetry.*