En meg szeretnem ha olyan programot irna valaki barmilyen nyelven, ami egy kafka streambol kiveszi a JSON uzeneteket, majd bizonyos mezok alapjan a megfelelo DB-be kuldi, ami lehet PostgreSQL, ES, stb. A program stateless legyen, de egy cachebe rogzitse a szamlalokat, valamint kepes legyen logolni JSON-ben mint formatumban es kezeljen sink-eket mint tavoli syslog, ES, Clickhouse endpointokat. Legyen neki egy monitoring API-ja es egy prometheus endpointja is (/metric), ami a cache-ben tarolt szamlalokat adja vissza.
Az alkalmazasnak kepesnek kell lennie bufferelni az adatokat, ha a storage endpoint nem erheto el, vagy reprocessalnia oket a kafka topikokbol.
Aki akarja irja meg C-ben, de mehet felolem Rust-ban is. :D