kafkaex / kafka_ex

Kafka client library for Elixir
MIT License
596 stars 162 forks source link

metadata cache does not get updated when producing event #445

Open yingyingtang-brex opened 3 years ago

yingyingtang-brex commented 3 years ago

To my understanding, when we produce a message with Topic A, the client will call server for metadata of the topic here.

However, we can see sometimes (not always), the metadata returned is for the previously produced topic (e.g. Topic B), rather than the current topic (e.g. Topic A) to be reproduced.

I suspect somehow the metadata cache was not updated, but not sure the root cause since its random issue.

Suggestions are appreciated!

nikunjy commented 2 years ago

@dantswain any thoughts on this ^