170 похожих чатов

Ребят подскажите пожалуйста зачем нужно создавать 2, 3 и больше

консьюмеров в очередях? На пример как создать в JMS и Кафка 3 consumer, просто 3 раза продублировать этот код? в JMS соответсвенно будет немного другая аннотация
@KafkaListener(topics = "myTopic")
public void receiveMessage(String message) {
System.out.println("Consumer received message: " + message);
}

И вообще зачем их создавать. Разве @JmsLisntere, @KafkaListener и так не каждый раз создают новый поток для каждого сообщения?

7 ответов

57 просмотров

Про то, что много консьюмеров - это много инстансов твоего приложения. Они объединются в консьюмер группу и вычитывают один топик

Влади́слав- Автор вопроса
D S
Про то, что много консьюмеров - это много инстансо...

Так если одна реплика приложения, то и консьюмер будет всегда, по твоей логике

каждый консьюмер закреплен за своей партицией, это позволяет чтение масштабировать

Влади́слав- Автор вопроса
D S
Про то, что много консьюмеров - это много инстансо...

а в консьюмер группу они сами соберутся, как гопники на стрелку, или надо что-то настроить?

Лол, нет, у тебя 1 поток на весь консьюмер, ты представляешь сколько потоков бы ты создал при обработке тысяч сообщений?

Влади́слав- Автор вопроса
Dima
Лол, нет, у тебя 1 поток на весь консьюмер, ты пре...

Ну да, я не говорю о создание 1000 поток что бы сервак загорелся А только о 2-3 условно

Влади́слав
Ну да, я не говорю о создание 1000 поток что бы се...

Я тебе написал модели масштабирования, пока начни различать листенер и консьюмер

Похожие вопросы

Обсуждают сегодня

Господа, а что сейчас вообще с рынком труда на делфи происходит? Какова ситуация?
Rꙮman Yankꙮvsky
29
А вообще, что может смущать в самой Julia - бы сказал, что нет единого стандартного подхода по многим моментам, поэтому многое выглядит как "хаки" и произвол. Короче говоря, с...
Viktor G.
2
30500 за редактор? )
Владимир
47
а через ESC-код ?
Alexey Kulakov
29
Чёт не понял, я ж правильной функцией воспользовался чтобы вывести отладочную информацию? но что-то она не ловится
notme
18
У меня есть функция где происходит это: write_bit(buffer, 1); write_bit(buffer, 0); write_bit(buffer, 1); write_bit(buffer, 1); write_bit(buffer, 1); w...
~
14
Добрый день! Скажите пожалуйста, а какие программы вы бы рекомендовали написать для того, чтобы научиться управлять памятью? Можно написать динамический массив, можно связный ...
Филипп
7
Недавно Google Project Zero нашёл багу в SQLite с помощью LLM, о чём достаточно было шумно в определённых интернетах, которые сопровождались рассказами, что скоро всех "ибешни...
Alex Sherbakov
5
Ребят в СИ можно реализовать ООП?
Николай
33
https://github.com/erlang/otp/blob/OTP-27.1/lib/kernel/src/logger_h_common.erl#L174 https://github.com/erlang/otp/blob/OTP-27.1/lib/kernel/src/logger_olp.erl#L76 15 лет назад...
Maksim Lapshin
20
Карта сайта