Быстро перенести несколько миллионов строк из БД в Kafka

В рамках одного Go-бинарника нужно вычитать несколько миллионов строк из базы и отправить их в очередь сообщений (например, Kafka) как можно быстрее. Как это сделать оптимально? Что будет узким местом и как обеспечить надёжность?