Currently when using DB retries, this is only configured to use Postgres, due to the driver being hardcoded on the following line. This should be dynamic so it can work with both Postgres and MySQL
https://github.com/inviqa/kafka-consumer-go/blob/master/config/config.go#L165
Currently when using DB retries, this is only configured to use Postgres, due to the driver being hardcoded on the following line. This should be dynamic so it can work with both Postgres and MySQL
https://github.com/inviqa/kafka-consumer-go/blob/master/config/config.go#L165