class WebSocketConsumersManager implements Runnable {

    public void removeConsumersForSessionId(final String sessionId) {
        synchronized (consumers) {
            consumers
                .entrySet()
                .stream()
                .filter((entry) -> entry.getKey().getSessionId().equals(sessionId))
                .forEach((entry) -> entry.getValue().requestStop());
        }
    }

    public  WebSocketConsumersManager(
        final WebKafkaConsumerFactory webKafkaConsumerFactory,
        final SimpMessagingTemplate messagingTemplate,
        final int maxConcurrentConsumers
    );
    public  WebSocketConsumersManager(
        final WebKafkaConsumerFactory webKafkaConsumerFactory,
        final SimpMessagingTemplate messagingTemplate,
        final ThreadPoolExecutor threadPoolExecutor
    );

}