diff --git a/src/main/java/com/sangdol/consumer/infrastructure/kafka/consumer/ConsumerPool.java b/src/main/java/com/sangdol/consumer/infrastructure/kafka/consumer/ConsumerPool.java new file mode 100644 index 0000000..a9cb816 --- /dev/null +++ b/src/main/java/com/sangdol/consumer/infrastructure/kafka/consumer/ConsumerPool.java @@ -0,0 +1,6 @@ +package com.sangdol.consumer.infrastructure.kafka.consumer; + +import java.util.concurrent.ExecutorService; + +public record ConsumerPool(ExecutorService executorService, int poolSize) { +}