[FEATURE] добавить в хуки kgo уведомление о измении статуса - коннект,дисконнект и тп #138

New Issue

vtolstov · 2024-12-06T19:10:12+03:00

vtolstov commented

2024-12-06 19:10:12 +03:00

No description provided.

vtolstov commented

2025-02-23 23:50:51 +03:00

default commit failed
If you need extra logic to track commit failure, I recommend overriding the commit callback. The default commit callback is only used if you do not specify your own. See https://pkg.go.dev/github.com/twmb/franz-go/pkg/kgo#AutoCommitCallback

we have connects and disconnects
https://pkg.go.dev/github.com/twmb/franz-go/pkg/kgo#HookBrokerConnect
https://pkg.go.dev/github.com/twmb/franz-go/pkg/kgo#HookBrokerDisconnect

on which hook/metrics i can understand that service must be stopped?
I think you'd be able to hook into the broker connect callback.

on heartbeat error also no hooks called
If a heartbeat experiences a non-retryable error, the group management goroutine exits and the OnPartitionsRevoked callback is called with the error.

default commit failed If you need extra logic to track commit failure, I recommend overriding the commit callback. The default commit callback is only used if you do not specify your own. See https://pkg.go.dev/github.com/twmb/franz-go/pkg/kgo#AutoCommitCallback we have connects and disconnects https://pkg.go.dev/github.com/twmb/franz-go/pkg/kgo#HookBrokerConnect https://pkg.go.dev/github.com/twmb/franz-go/pkg/kgo#HookBrokerDisconnect on which hook/metrics i can understand that service must be stopped? I think you'd be able to hook into the broker connect callback. on heartbeat error also no hooks called If a heartbeat experiences a non-retryable error, the group management goroutine exits and the OnPartitionsRevoked callback is called with the error.

Sign in to join this conversation.

1 Participants

Notifications

Due Date

No due date set.

Dependencies

No dependencies set.

Reference: unistack-org/micro-broker-kgo#138