#node.js #kubernetes #lag #consumer #kafkajs
#node.js #kubernetes #задержка #потребитель #kafkaj
Вопрос:
нужна помощь с задержкой пользователя kafkaj
один модуль kubernetes отправляет 10 сообщений в queque, последнее смещение в kafdrop равно 10, все сообщения успешно доставляются в стороннюю систему и успешно передаются
но, и это случайно, в kafdrop есть задержка потребителя, иногда 1 сообщение, иногда 3 .., состояние в kafdrop, например: последнее смещение 10, смещение потребителя 8, но все сообщения, отправленные kafkaj и доставленные в стороннюю систему
если мы отправим еще 10 сообщений в kafka, все будет в порядке, если мы перезапустим модуль потребителей, сообщения с задержкой отправляются и отправляются дважды
kafkaj настроен на ручную фиксацию после ответа третьей стороны
пожалуйста, несколько советов