👨C
но у тебя проблема как раз после брокера...
Size: a a a
2018 August 13
OV
A
Похоже на систему ощадбанка или укрпочты. Нужно создать очередь в очереди, чтобы люди могли стоять в очереди, пока стоят в очереди.
👨C
ну вариант
1. поменять логику, kafka должна решать проблему, а не создавать
2. for-await-of
3. написать свой EventEmmiter, унаследованный от клиента kafka и там самому попытаться все разрулить...
1. поменять логику, kafka должна решать проблему, а не создавать
2. for-await-of
3. написать свой EventEmmiter, унаследованный от клиента kafka и там самому попытаться все разрулить...
👨C
Похоже на систему ощадбанка или укрпочты. Нужно создать очередь в очереди, чтобы люди могли стоять в очереди, пока стоят в очереди.
😂
OV
Я чего сюда и написал, " очередь-очередей" звучит даже дико. Вот пытаюсь разрулить.
👨C
Я чего сюда и написал, " очередь-очередей" звучит даже дико. Вот пытаюсь разрулить.
ну извини, предложили с @m03geek, что могли 💁♂️
OV
Нормально, спасибо. Разрулил.
👨C
Нормально, спасибо. Разрулил.
о, и как?)
2018 August 14
OV
У kafka есть в message свойство highWaterOffset. Ставлю на паузу consumer и считываю сообщения до этого значения в массив, добавляю промис в метод обработчика и запускаю ассинхронный итератор, по завершеню снимаю с паузы
👨C
У kafka есть в message свойство highWaterOffset. Ставлю на паузу consumer и считываю сообщения до этого значения в массив, добавляю промис в метод обработчика и запускаю ассинхронный итератор, по завершеню снимаю с паузы
ах, хитрая жопа!) Прикольно)
2018 August 17
A
У kafka есть в message свойство highWaterOffset. Ставлю на паузу consumer и считываю сообщения до этого значения в массив, добавляю промис в метод обработчика и запускаю ассинхронный итератор, по завершеню снимаю с паузы
вообще, звучит как задача для нодовских стримов
A
я не читал тред выше, но конкретно это сообщение буквально звучит как описание того, как из коробки работает stream.Readable
D
я не читал тред выше, но конкретно это сообщение буквально звучит как описание того, как из коробки работает stream.Readable
+
D
Ток не совсем ридабл а если ты через 'readable' ивент читаешь
D
Так то если ты через дата или пайп то будет pull based и он все читать бу
2018 August 18
Вт
привет бекендеры
2018 August 19
BT
фронтендеры тоже тут
VS
Ми просто прийшли з чатику @frontendua, гг