@KafkaListener(topics = "myTopic")
public void receiveMessage(String message) {
System.out.println("Consumer received message: " + message);
}
вообще не имеет смыла, так ведь?
сделай concurrentConsumerListener
консьюмер по дефолту не конкурентный?
Это что бы оно создавало куча в разных поток одновременно считывало сообщения, а не по одному?
ты можешь в одном инстансе много консюмеров намножить
Если говорить за обычный JMS, где не юзается партиция, то оно просто паралельно будет их считывать кучами? Я пока кафку только начал учить, еще не особо вкурил партиции
ну, это здорово, но оно как будто не скейлиться, как мне кажется) Если конечно там не какое-то здоровое блокиующее IO
кучи тоже отдельно настраивать надо
Это абстракция про листенеры, консьюмеры ты в спринг-кафка можешь скейлить или внутри приложения - concurrency level, или на уровне инфры - 1 инстанс/1 консьюмер, или оба подхода
Обсуждают сегодня