kafkaでpublishのロジックを独自に作ってデータロスを無くす話