You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
ReadMessage ends up in a loop and does not return when kafka broker gets deleted
Kafka Version
What version(s) of Kafka are you testing against? 3.6.0.redhat-00005
What version of kafka-go are you using? 0.4.47
To Reproduce
Install kafka on a separate namespace and controller that reads from kafka in a separate namespace
Uninstall kafka from a namespace this causes the ReadMessage call in a controller that is in a separate namespace hangs and does not return
Noticing below error in a loop
2024-05-23T02:07:05Z ERROR controllers.ServiceInstance Kafka Error {"error": "failed to dial: failed to open connection to a.b.c.d:9093: dial tcp: lookup a.b.c.d on xx.xx.xx.xx: no such host"}
github.com/segmentio/kafka-go.(*Reader).run.func2
/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/reader.go:314
github.com/segmentio/kafka-go.(*Reader).withErrorLogger
/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/reader.go:1137
github.com/segmentio/kafka-go.(*Reader).run
Expected Behavior
Expect the Readmessage to return with proper error that way we can handle gracefully if user deletes kafka broker while our controller is in a Read block.
Observed Behavior
A clear and concise description of the behavior you observed.
Below message is printed in a loop and ReadMessage does not return
2024-05-23T02:07:05Z ERROR controllers.ServiceInstance Kafka Error {"error": "failed to dial: failed to open connection to a.b.c.d:9093: dial tcp: lookup a.b.c.d on xx.xx.xx.xx: no such host"}
github.com/segmentio/kafka-go.(*Reader).run.func2
/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/reader.go:314
github.com/segmentio/kafka-go.(*Reader).withErrorLogger
/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/reader.go:1137
github.com/segmentio/kafka-go.(*Reader).run
The text was updated successfully, but these errors were encountered:
Describe the bug
Kafka Version
To Reproduce
Install kafka on a separate namespace and controller that reads from kafka in a separate namespace
Uninstall kafka from a namespace this causes the ReadMessage call in a controller that is in a separate namespace hangs and does not return
Noticing below error in a loop
Expected Behavior
Observed Behavior
Below message is printed in a loop and ReadMessage does not return
The text was updated successfully, but these errors were encountered: