хм

не буду обрубать запрос, может пройдет через сколько то времени

надо обрубить

./noc liftbridge set-cursor --name classifier --stream events --offset 0

и команду выполнить

готово

в логе классификатора что-нибудь поменялось?

пока нет

а если перезапустить?

теперь показывает 1

2021-10-07 16:34:22,232 [noc.core.liftbridge.base] Refresh leaders
2021-10-07 16:34:22,236 [noc.core.liftbridge.base] Failed to get cursor: <AioRpcError of RPC that terminated with:
       status = StatusCode.INTERNAL
       details = "rpc error: code = Internal desc = Failed to create stream reader: segment not found"
       debug_error_string = "{"created":"@1633606462.235875077","description":"Error received from peer ipv4:чч.чч.12.100:9292","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"rpc error: code = Internal desc = Failed to create stream reader: segment not found","grpc_status":13}"

любопытно, да

journalctl -u liftbridge надо бы сохранить в файлик

root@Node01:/opt/noc# systemctl status liftbridge
● liftbridge.service - Liftbridge service
  Loaded: loaded (/lib/systemd/system/liftbridge.service; enabled; vendor preset: enabled)
  Active: active (running) since Wed 2021-09-22 13:05:09 +05; 2 weeks 1 days ago
Main PID: 661 (liftbridge)
   Tasks: 13 (limit: 19660)
  Memory: 32.1M
  CGroup: /system.slice/liftbridge.service
          └─661 /bin/liftbridge --config=/etc/liftbridge/liftbridge.yml

окт 07 16:35:46 Node01 liftbridge[661]: time="2021-10-07 16:35:46" level=error msg="api: Failed to subscribe to partition [subject=liftbridge-default.cursors, stream=__cursors, partition=0]: rpc error: cod
окт 07 16:35:47 Node01 liftbridge[661]: time="2021-10-07 16:35:47" level=error msg="api: Failed to subscribe to partition [subject=liftbridge-default.cursors, stream=__cursors, partition=0]: rpc error: cod
окт 07 16:35:47 Node01 liftbridge[661]: time="2021-10-07 16:35:47" level=error msg="api: Failed to subscribe to partition [subject=liftbridge-default.cursors, stream=__cursors, partition=0]: rpc error: cod
окт 07 16:35:48 Node01 liftbridge[661]: time="2021-10-07 16:35:48" level=error msg="api: Failed to subscribe to partition [subject=liftbridge-default.cursors, stream=__cursors, partition=0]: rpc error: cod
окт 07 16:35:48 Node01 liftbridge[661]: time="2021-10-07 16:35:48" level=error msg="api: Failed to subscribe to partition [subject=liftbridge-default.cursors, stream=__cursors, partition=0]: rpc error: cod
окт 07 16:35:48 Node01 liftbridge[661]: time="2021-10-07 16:35:48" level=error msg="api: Failed to subscribe to partition [subject=liftbridge-default.cursors, stream=__cursors, partition=0]: rpc error: cod
окт 07 16:35:49 Node01 liftbridge[661]: time="2021-10-07 16:35:49" level=error msg="api: Failed to subscribe to partition [subject=liftbridge-default.cursors, stream=__cursors, partition=0]: rpc error: cod
окт 07 16:35:49 Node01 liftbridge[661]: time="2021-10-07 16:35:49" level=error msg="api: Failed to subscribe to partition [subject=liftbridge-default.cursors, stream=__cursors, partition=0]: rpc error: cod
окт 07 16:35:50 Node01 liftbridge[661]: time="2021-10-07 16:35:50" level=error msg="api: Failed to subscribe to partition [subject=liftbridge-default.cursors, stream=__cursors, partition=0]: rpc error: cod
окт 07 16:35:50 Node01 liftbridge[661]: time="2021-10-07 16:35:50" level=error msg="api: Failed to subscribe to partition [subject=liftbridge-default.cursors, stream=__cursors, partition=0]: rpc error: cod

потом systemctl stop liftbridge
rm -rf /var/lib/liftbridge/*,
systemctl start liftbridge

после старта

Ensuring stream events.default
Creating stream events.default with 2 partitions
CHANGED

классификатор запустился?

да