Kafka sidecar microservice (golang)

мне нужно запилить kafka sidecar, который слушает кафку дергает роут и отправляет в кафку сообщение
- подержка кафка режестри (AVRO)
- из ENV читать топик, ручку какую дергать
- рука микросервиса представляет собой POST на вход Kafka Event на выход, Kafka сообщения которые нужно отправить, если роут от дает 200, и сообщение отправилось в топик, то коммитим
- если есть какие то ошибки ложем микросервис (если опция включена в ENV) в противном случае в логи плюем ошибку и едим дальше
- в логи плюем сообщения из топика и в топик