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

Я понял, то есть дублирование

@KafkaListener(topics = "myTopic")
public void receiveMessage(String message) {
System.out.println("Consumer received message: " + message);
}

вообще не имеет смыла, так ведь?

8 ответов

8 просмотров

сделай concurrentConsumerListener

Роман
сделай concurrentConsumerListener

консьюмер по дефолту не конкурентный?

Влади́слав- Автор вопроса
Роман
сделай concurrentConsumerListener

Это что бы оно создавало куча в разных поток одновременно считывало сообщения, а не по одному?

D S
консьюмер по дефолту не конкурентный?

ты можешь в одном инстансе много консюмеров намножить

Влади́слав- Автор вопроса
Роман
сделай concurrentConsumerListener

Если говорить за обычный JMS, где не юзается партиция, то оно просто паралельно будет их считывать кучами? Я пока кафку только начал учить, еще не особо вкурил партиции

Роман
ты можешь в одном инстансе много консюмеров намнож...

ну, это здорово, но оно как будто не скейлиться, как мне кажется) Если конечно там не какое-то здоровое блокиующее IO

Это абстракция про листенеры, консьюмеры ты в спринг-кафка можешь скейлить или внутри приложения - concurrency level, или на уровне инфры - 1 инстанс/1 консьюмер, или оба подхода

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

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

я не магистр хаскеля, но разве не может лейзи тип конвертнуться в не-лейзи запросив вычисление содержимого прям при инициализации?
deadgnom32 λ madao
80
читать файл максимально быстро? странный вопрос))
zamtmn
53
How to create an OS in C? what to study?
Linus
18
Всем доброго вечера! Хочу поделиться своим злоключением с человеком, который, как оказалось сюда тоже скидывал свое резюме. Жаль, что я вашу группу не нашел раньше… человек ки...
Роман Ахмедзянов
4
тоесть, указав return eax, сгенерируется никому ненужная инструкция mov eax,eax ?
Aiwan \ (•◡•) / _bot
24
Компания Elif ищет менеджера проектов, который будет заниматься поиском и ведением новых проектов. Прежде чем приступить к работе, вам нужно пройти наш недельный курс, где вы ...
Elif
5
Привет, кто может сделать юзербота с апи? Задачи: - создавать группы - создавать каналы - задавать для созданных каналов аватарку или эмоджи, имя группы - добавлять в группы...
Lencore
11
Вопрос вроде правильно, но что надо сделать, чтоб текст был виден нормально ? ghci> TE.decodeUtf8 $ TE.encodeUtf8 "test - проба" "test - \1087\1088\1086\1073\1072"
Fedor
7
а зачем этот вопрос для удаления из чата?
Mёdkinson Medvezhkin
63
@HemulGM Параметры у AddStream поменялись? Несостыковка какая-то
Катерина Свиридова
12
Карта сайта