AA
./noc liftbridge --debug fetch-cursor --name classifier --stream events.defaultSize: a a a
2020 December 10
AA
а вот так?
AA
cat /etc/liftbridge/liftbridge.ymlAA
а там что?
F
./noc liftbridge --debug fetch-cursor --name classifier --stream events.default
F
cat /etc/liftbridge/liftbridge.ymlclustering:
raft.bootstrap.seed: true
server.id: n1.noc.wrk.new.ru
cursors:
stream.auto.pause.time: 0
stream.partitions: 1
data:
dir: /var/lib/liftbridge
host: 10.85.10.19
logging:
level: info
raft: true
nats.servers:
- nats://10.85.10.19:4222
streams:
compact.enabled: false
retention.max:
age: 24hF
причем в /var/lib/liftbridge сообщения есть в логах
F
про пинги
F
и failed и OK
AA
./noc liftbridge subscribe --name events.defaultF
./noc liftbridge subscribe --name events.default# Subject: events.default Partition: 0 Offset: 0 Timestamp: 1607584356541638039 Key: b'' Headers: {'subject': b'events.default', 'reply': b''}
b'{"ts":1607584353.5310292,"object":"6","data":{"source":"system","$event":{"class":"NOC | Managed Object | Ping Failed","vars":{}}}}'F
вот таких сообщений много
F
где-то, естественно, Ping OK
AA
понятно да, счас подумаем
AA
вот тут
/etc/liftbridge/liftbridge.yml сделать stream.partitions: 0. И перезапустить liftbridge./noc liftbridge show-metadata проверить есть ли там __cursorsF
вот тут
/etc/liftbridge/liftbridge.yml сделать stream.partitions: 0. И перезапустить liftbridge./noc liftbridge show-metadata проверить есть ли там __cursorsсделал, есть
# Streams
## Name: __cursors Subject: liftbridge-default.cursorsF
но классификатор не рад
F
2020-12-10 10:51:54,263 [noc.core.liftbridge.base] Failed to get cursor: <AioRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "Socket closed"
debug_error_string = "{"created":"@1607586714.261771350","description":"Error received from peer ipv4:10.85.10.19:9292","file":"src/core/lib/surface/call.cc","file_line":1061,"grpc_message":"Socket closed","grpc_status":14}"
>AA
./noc liftbridge delete-stream --name __cursorsAA
пройдёт?