kafka listener for fixed backoff

FixedBackOffKafkaListener.kt

@Component
class FixedBackOffKafkaListener {
    private val log = LoggerFactory.getLogger(FixedBackOffKafkaListener::class.java)

    @KafkaListener(
        id = "\${spring.kafka.consumer.group-id}",
        topics = ["\${topic}"]
    )
    fun onReceive(message: String) {
        log.info("processing message: $message")
        throw Exception()
    }
}