|
@@ -61,7 +61,7 @@ class ProcessRecordingSegmentStrategy(ProcessingStrategy[KafkaPayload]):
|
|
|
) -> None:
|
|
|
self.__closed = False
|
|
|
self.__futures: Deque[ReplayRecordingMessageFuture] = deque()
|
|
|
- self.__threadpool = concurrent.futures.ThreadPoolExecutor()
|
|
|
+ self.__threadpool = concurrent.futures.ThreadPoolExecutor(max_workers=16)
|
|
|
self.__commit = commit
|
|
|
self.__commit_data: MutableMapping[Partition, Position] = {}
|
|
|
self.__last_committed: float = 0
|