diff --git a/src/backend/streaming-server/src/main/kotlin/com/lalala/streaming/external/kafka/KafkaProducer.kt b/src/backend/streaming-server/src/main/kotlin/com/lalala/streaming/external/kafka/KafkaProducer.kt index 3d1ff2be..a25b5f17 100644 --- a/src/backend/streaming-server/src/main/kotlin/com/lalala/streaming/external/kafka/KafkaProducer.kt +++ b/src/backend/streaming-server/src/main/kotlin/com/lalala/streaming/external/kafka/KafkaProducer.kt @@ -9,7 +9,7 @@ import org.springframework.stereotype.Component class KafkaProducer( private val template: KafkaTemplate ) { - @Async + @Async("asyncProducerExecutor") fun execute(event: LalalaEvent) { template.send(event.topic, event) }