Change Details

Collect here all minor features and work needed by HAProxyKafka Required for production deployment: - [x] Secure connect to kafka cluster (TLS) - [] Debian packaging/CI/Puppetization - [x] Tuning Kakfa message batching - [x] Trim all unnecessary fields and transformations from produced json (@gmodena can help with this) - [] Better grafana dashboard - [] Alerts Other features (some still need to be evaluated): - [x] Logging level from CLI/Configuration - [] Retry logic on some errors - [] UDP socket support (in addition to UDS) - [] Systemd socket activation - [] Configuration auto-reloading on file change - [] Tests for received `kafka.Error` errors - [] metrics tests Fixes - [] Messages sent to DLQ have empty `Error` field

Collect here all minor features and work needed by HAProxyKafka Required for production deployment: - [x] Secure connect to kafka cluster (TLS) - [] ~~Debian packaging/CI/Puppetization~~ (T377614, T377613) - [x] Tuning Kakfa message batching - [x] Trim all unnecessary fields and transformations from produced json (@gmodena can help with this) - [] Better grafana dashboard - [] Alerts Other features (some still need to be evaluated): - [x] Logging level from CLI/Configuration - [] Retry logic on some errors - [] UDP socket support (in addition to UDS) - [] Systemd socket activation - [] Configuration auto-reloading on file change - [] Tests for received `kafka.Error` errors - [] metrics tests Fixes - [] Messages sent to DLQ have empty `Error` field

Collect here all minor features and work needed by HAProxyKafka Required for production deployment: - [x] Secure connect to kafka cluster (TLS) - [] ~~Debian packaging/CI/Puppetization~~ (T377614, T377613) - [x] Tuning Kakfa message batching - [x] Trim all unnecessary fields and transformations from produced json (@gmodena can help with this) - [] Better grafana dashboard - [] Alerts Other features (some still need to be evaluated): - [x] Logging level from CLI/Configuration - [] Retry logic on some errors - [] UDP socket support (in addition to UDS) - [] Systemd socket activation - [] Configuration auto-reloading on file change - [] Tests for received `kafka.Error` errors - [] metrics tests Fixes - [] Messages sent to DLQ have empty `Error` field