Код-ревью: обработка платежей из Kafka

@Service
public class PaymentEvents {
    private final KafkaTemplate<String, PaymentEvent> kafka;
    private final PaymentRepository repo;
    private final RestClient bank;

    public PaymentEvents(KafkaTemplate<String, PaymentEvent> kafka,
                         PaymentRepository repo, RestClient bank) {
        this.kafka = kafka;
        this.repo = repo;
        this.bank = bank;
    }

    @Transactional
    public void pay(Payment p) {
        repo.save(p);
        kafka.send("payments", UUID.randomUUID().toString(), new PaymentEvent(p.getId()));
    }

    @KafkaListener(topics = "payments", groupId = "ledger", concurrency = "12")
    public void onPayment(PaymentEvent e) {
        repo.insertLedgerEntry(e.paymentId());
        bank.post().uri("/notify").body(e).retrieve().toBodilessEntity();
    }
}