NG
Да-да, я про это же))
Size: a a a
2021 June 08
D
А можете тукнуть где есть полный пример?Я запускаю отправку по одному сообщению каждую секунду. Если я ставлю таймаут 5с у consume. то оно читает только то что пришло до вызова метода, а потом 5 секунд просто висит и вы ходит, запускаю ещё раз читает следующие 5 сообщений которые успели отправиться и опять висит, то есть оно не слушает все эти 5 секунд, а просто ждёт таймаута
NG
Вы отправку и чтение в одном потоке делаете или в разных?
of
Эм.. Http сервис и соединение... Или я не понял вопроса
NG
Ну, Kafka stream != Kafka все же
D
В разных. Для теста запустил две 1с, в одной в цикле отправляю, в другой в цикле читаю
D
of
Нуу да.... У меня просто в проде только стрим пока. А так там целый мир блин :(
NG
Сколько задержка слева?
D
Вот более наглядно. Задержка 1 секунда
D
Т.е. сообщение отправляется каждую секунду, а читается раз в 5 секунд. Я так понимаю если обработка одного сообщения будет больше таймаута чтения и мы его не успеем подтвердить, то оно опять прочитается и надо контролировать какое сообщение уже обрабатывается, а какое нет?
NG
Хм. Вообще это как-то не нормально. Можно попробовать написать баг репорт в репе компоненты на гитхабе.
AO
И чо, что хттп там сторонний, и что это стриминг? Теперь из 1С нельзя юзать?
NG
Не, таймаут чтения - это про ожидание помещения сообщения из очереди в память компоненты. Пока компонента не ответит ack/nack/reject или клиент не порвёт соединение целиком, сообщение будет считаться "занятым"
D
Ну ок, пойду оставлю, спасибо
D
То есть если мы запустим параллельно два чтения, одно чтение обрабатывает сообщение, второе чтение его не полчит, так как ребит пометит его занятым?
NG
@stalnoy компонента ж жива ещё? Пилите её?
NG
D
Отлично, спасибо. Тогда пошёл писать багрепорт и копать дальше
of
Ну в кролике тоже был сторонний http который был еле живой. Я хз просто насколько он в кафке стабилен. Кроме 1С врядли ведь ещё где то нужен. У всех уже есть коннекторы прямые