lefebsy/json2kafka repository overview

⁠REST microService : Json to Kafka

• Code : dotNetcore v5.0 - linux alpine self-contained compiled
• Docker images : https://hub.docker.com/r/lefebsy/json2kafka/tags⁠
• Memory needed : ~ 30Mo

⁠Main features

• Designed for kubernetes, all settings can be setted by environnements variables or a configmap appsettings.json file
• Liveness and readiness probes ready /health
• Can publish on a Kafka with TLS and Sasl username/password
• The REST API can be exposed with a simple basicAuth login/password
• Logs JSON formated compliant with kubernetes annotations elastic.co to be parsed and displayed in Kibana

⁠How to use

• Method : POST
• URI : /api/msg
• Content-Type : application/json
• Format : UTF-8
• Body : Json document
• [BasicAuth] : username and password header

⁠Configuration

• kafka : read the service settings⁠

⁠It is not !

• There is NO authentication impersonation, REST credentials are not played as Kafka credentials
• This code is not fully tested, it is a very simple project to test Kafka in dotnetCore microservice