我有一个Kafka的听众在接收avro信息：

@Service
class MyListener(private val useCase: MyUseCase) {
    @KafkaListener(topics = ["\${app.topic}"], autoStartup = "\${app.event.auto-startup:true}")
    fun listen(message: decision_made_v1) {
        useCase.perform(message.payload)
    }
}

在我的应用程序的另一部分中，有一个存储库操作：

@Component
class CreateCreditAnalysisUseCase(private val myRepository: MyRepository) {
    fun execute(command: MyCommand): CreditAnalysis {
        return myRepository.save(command)
    }
}

我怎样才能让我的Kafka听众接收和呼叫 useCase.perform 只有在 myRepository.save 在db中提交？