Ang Li

Results 3 comments of Ang Li

I think I have a similar problem with creating topics after a kafka cluster rolling restart. I got an error log `"Coordinator for topic is not available"` and `::topic_not_found`. Producing...

@ulutomaz If you still have the issue, you can try an OTP upgrade https://github.com/kafkaex/kafka_ex/issues/389#issuecomment-1062515469 BTW, we're also on AWS MSK (2.3.1).

Hi Dan, thank you for your reply. I made a fix on L65, and the crash disappeared. https://github.com/kafkaex/kafka_ex/blob/master/lib/kafka_ex/network_client.ex#L65 I think you're right that the broker closed the connection. I was...