diff --git a/broker.go b/broker.go index fbd6772..0af77fa 100644 --- a/broker.go +++ b/broker.go @@ -27,7 +27,7 @@ var ( func (m *hookEvent) OnGroupManageError(err error) { if err != nil { - m.connected.Store(0) + // m.connected.Store(0) if m.fatalOnError { m.log.Fatal(context.TODO(), "kgo.OnGroupManageError", err) } @@ -36,7 +36,7 @@ func (m *hookEvent) OnGroupManageError(err error) { func (m *hookEvent) OnBrokerConnect(_ kgo.BrokerMetadata, _ time.Duration, _ net.Conn, err error) { if err != nil { - m.connected.Store(0) + // m.connected.Store(0) if m.fatalOnError { m.log.Fatal(context.TODO(), "kgo.OnBrokerConnect", err) } @@ -44,12 +44,12 @@ func (m *hookEvent) OnBrokerConnect(_ kgo.BrokerMetadata, _ time.Duration, _ net } func (m *hookEvent) OnBrokerDisconnect(_ kgo.BrokerMetadata, _ net.Conn) { - m.connected.Store(0) + // m.connected.Store(0) } func (m *hookEvent) OnBrokerWrite(_ kgo.BrokerMetadata, _ int16, _ int, _ time.Duration, _ time.Duration, err error) { if err != nil { - m.connected.Store(0) + // m.connected.Store(0) if m.fatalOnError { m.log.Fatal(context.TODO(), "kgo.OnBrokerWrite", err) } @@ -58,12 +58,12 @@ func (m *hookEvent) OnBrokerWrite(_ kgo.BrokerMetadata, _ int16, _ int, _ time.D func (m *hookEvent) OnBrokerRead(_ kgo.BrokerMetadata, _ int16, _ int, _ time.Duration, _ time.Duration, err error) { if err != nil { - m.connected.Store(0) + // m.connected.Store(0) } } func (m *hookEvent) OnProduceRecordUnbuffered(_ *kgo.Record, err error) { if err != nil { - m.connected.Store(0) + // m.connected.Store(0) } }