консьюмеров в очередях? На пример как создать в JMS и Кафка 3 consumer, просто 3 раза продублировать этот код? в JMS соответсвенно будет немного другая аннотация
@KafkaListener(topics = "myTopic")
public void receiveMessage(String message) {
System.out.println("Consumer received message: " + message);
}
И вообще зачем их создавать. Разве @JmsLisntere, @KafkaListener и так не каждый раз создают новый поток для каждого сообщения?
Про то, что много консьюмеров - это много инстансов твоего приложения. Они объединются в консьюмер группу и вычитывают один топик
Так если одна реплика приложения, то и консьюмер будет всегда, по твоей логике
каждый консьюмер закреплен за своей партицией, это позволяет чтение масштабировать
а в консьюмер группу они сами соберутся, как гопники на стрелку, или надо что-то настроить?
Лол, нет, у тебя 1 поток на весь консьюмер, ты представляешь сколько потоков бы ты создал при обработке тысяч сообщений?
Ну да, я не говорю о создание 1000 поток что бы сервак загорелся А только о 2-3 условно
Я тебе написал модели масштабирования, пока начни различать листенер и консьюмер
Обсуждают сегодня